Parallel.For 列表<Int32>

Question

我写了以下几行代码：

    private static List<Int32> GetRandomList_Serial()
    {
        List<Int32> returnValue = new List<int>();
        Random random = new Random();

        for (int i = 0; i < 10000000; i++)
        {
            returnValue.Add(random.Next());
        }
        returnValue.Sort();
        return returnValue;
    }

然后我写了这段代码：

    private static List<Int32> GetRandomList_Parallel()
    {
        List<Int32> returnValue = new List<int>();
        Random random = new Random();

        Parallel.For(0, 10000000, y =>
        {
            returnValue.Add(random.Next());
        });

        returnValue.Sort();
        return returnValue;

    }

串行工作正常，并行抛出此异常：

System.ArgumentException 未被用户代码处理

目标数组不够长。检查 destIndex 和长度，以及数组的下限。

有人知道为什么吗？

Answer 1

您使用的 List 不是线程安全的。使用 ConcurrentBag。我在切换到并行循环时一直遇到这个问题。它会间歇性地发生，并非每次都发生，因此很难检测到。

Answer 2

是的，List<> 不是线程安全的。但是，您可以通过将 List 预分配到您想要的大小来并行化，然后使用 []（索引）来填充值。

换句话说，不要并行增长你的数组。一开始就种植，然后并行填充。

编辑：

更多信息。

List<> 是一个简单的数组，可以为了方便而增长。因此，如果您预先分配它（一开始就将它增加到 1000 的 LENGTH），它的大小 (.Count) 在填充过程中不会改变。

因此，如果 Parallel.For 使用任何类型的分区，它将为将处理循环的每个线程分配不同的索引。并且，数组的每个 ELEMENT 将被精确填充一次。

我认为这没有任何问题，除了Random.Next() 不是线程安全的并且可能返回乱码。但是，它应该这样做，对吧？

新编辑：

更多信息：

如果需要使用 List，则预分配意味着：

List<int> myList=new List<int>(MY_COUNT);
//  very unefficient method of pre-allocation, 
//  but there is no other way to assign .Count
for (int n=0; n<MY_COUNT; n++) {
    myList.Add(0);
}
//  proceed with Parallel.For

如果您可以将类型切换为其他类型，我会为此推荐一个数组：

int[] myList=new int[MY_COUNT];
//  proceed with Parallel.For