c# – Parallel.ForEach同时保留订单

如果是这样,是的,操作很简单.不要理会锁定或同步构造,这些会侵蚀并行化带给您的所有速度.

相反,如果遵守这个简单的规则,任何算法都可以并行化,而无需锁定或同步：

For each input element X[i] processed,you may read from any input element X[j],but only write to output element Y[i]

查找Scatter / Gather,这种类型的操作称为聚集,因为只写入一个输出元素.

如果你可以使用上面的原则,那么你想要在前面创建输出数组Foo [],并在输入数组上使用Parallel.For not ForEach.

例如.

List<byte[]> inputArray = new List<byte[]>();
        int[] outputArray = new int[inputArray.Count];

        var waitHandle = new ManualResetEvent(false);
        int counter = 0;

        Parallel.For(0,inputArray.Count,index =>
            {
                // Pass index to for loop,do long running operation 
                // on input items
                // writing to only a single output item
                outputArray[index] = DoOperation(inputArray[index]);

                if(Interlocked.Increment(ref counter) == inputArray.Count -1)
                {
                    waitHandle.Set();
                }
            });

        waitHandler.WaitOne();

        // Optional conversion back to list if you wanted this
        var outputList = outputArray.ToList();