11

可能重复：
并行处理期间的 C# 值存储

我今天在我的控制台应用程序中运行了一些性能测试，我偶然发现了一些非常出乎意料的东西。我的代码：

int iterations = 1000000;

var mainList = new List<string>();

for (int i = 0; i < iterations; i++)
{
    mainList.Add(i.ToString());
}

var listA = new List<string>();

Parallel.ForEach(mainList, (listItem) =>
                           {
                               if (Int32.Parse(listItem)%2 == 0)
                               {
                                   listA.Add(listItem);
                               }
                           });

Console.WriteLine("Parallel Count: {0}", listA.Count);

var listB = new List<string>();
foreach (var listItem in mainList)
{
    if (Int32.Parse(listItem) % 2 == 0)
    {
        listB.Add(listItem);
    }
}

Console.WriteLine("Sequential Count: {0}", listB.Count);

这导致了一个输出：

并行计数：495939

连续计数：500000

我跑了好几次，并行循环似乎从来没有在适当的时间执行过。谁能解释这种“不当行为”？并行循环是否可信？

PS 我知道在提供的代码示例中发生了很多废话，例如 ToString() 调用整数而不是解析它们，但这只是我在测试时想出的随机代码。提前致谢。

4

1 回答 1

15

你的问题不在于Parallel.ForEach. 您的问题在于List<int>- 该类不是线程安全的。我的猜测是您遇到了列表对象的线程安全问题。尝试使用 aConcurrentBag<int>代替，问题可能会消失。

来自 Microsoft 关于线程安全的List<T>：

要允许集合被多个线程访问以进行读写，您必须实现自己的同步。

于 2012-12-29T18:31:20.437 回答