Parallel.ForEach丢失数据

Question

Parallel.ForEach有助于提高性能，但是，我看到数据丢失了。

尝试变量结果，processedData为ConcurrentBag<IwrRows>。

1)

Parallel.ForEach(results, () => new ConcurrentBag<IwrRows>(), (n, loopState, localData)    =>
{
 return ProcessData(n); // ProcessData complicated business logic
}, (localData) => AddRows(localData, processedData, obj)
);

2)

await Task.Run(() => Parallel.ForEach(results, item =>
        {
            ProcessData(item, processedData);  
        }));

3)

Parallel.ForEach(results, item =>
 {
 ProcessData(item, processedData);
 });

他们都输掉了几排。

当我使用foreach块时，它会始终如一地返回相同的值，但是它的速度要慢4倍。

foreach (var item in results)
        {
            // ProcessData returns a List<IwrRows>
            processedData.AddRange(ProcessData(item));
        }

不知道我在这里错过了什么。

结果- 51112 Foreach返回41316行返回。ForeachParallel返回的41308或41313或41314随每次运行而不同。

Answer 1

你似乎在为结果而挣扎，并把它们重新列入一个连贯的列表中。您可以使用PLinQ，这样就不必费心使用线程安全的结果容器了：

var processedData = yourData.AsParallel().Select(ProcessData).ToList();

Answer 2

您的问题似乎出现在: AddRows(localData，processedData，obj)中。此方法可能是将数据添加到一个不是线程安全的列表中。您应该添加到线程安全列表中，或者在添加数据时进行一些同步。

Answer 3

我认为在2)中使用await Task.Run是无用的。

如果Foreach returns 41316 rows back for Results - 51112的问题不在Parallel.ForEach中，而是在您的添加/处理机制中。请记住，即使ConcurrentBag保证其上的每个操作都是线程安全的，它也不会处理重复的操作。