使用 Parallel.ForEach() 实现收益返回的线程安全

考虑以下代码示例，它创建一个可枚举的整数集合并并行处理它：

using System.Collections.Generic;
using System.Threading.Tasks;

public class Program
{
    public static void Main()
    {
        Parallel.ForEach(CreateItems(100), item => ProcessItem(item));
    }

    private static IEnumerable<int> CreateItems(int count)
    {
        for (int i = 0; i < count; i++)
        {
            yield return i;
        }
    }

    private static void ProcessItem(int item)
    {
        // Do something
    }
}

是否保证生成的工作线程Parallel.ForEach()每个都获得不同的项目，或者是围绕增量和返回的某种锁定机制i必需的？

Parallel.ForEach<TSource>, when TSource is an IEnumerable<T>，创建一个分区器IEnumerable<T>其中包括它自己的内部锁定机构，因此您不需要在迭代器中实现任何线程安全。

每当工作线程请求一块项目时，分区器就会创建一个内部枚举器, which:

1. 获取共享锁
2. 迭代源（从剩下的位置）以检索项目块，将项目保存在私有数组中
3. 释放锁，以便可以满足其他块请求。
4. 从其私有数组为工作线程提供服务。

如您所见，运行通过IEnumerable<T>出于分区目的，分区是顺序的（通过共享锁访问），并且分区是并行处理的。