TaskFactory.Tasks 中 BlockingCollection.GetConsumingEnumerable() 集合的 Parallel.ForEach 和 foreach 循环

Question

我已经对这两个循环进行了试验，并注意到即使 Task 的 Action 委托中的常规 foreach 循环应该并行执行，它也不会并行处理元素。但是，如果我用 Parallel.ForEach 替换它，我会看到数据正在跨多个线程并行处理。

代码 1：

Task loadingTask1 = Factory.StartNew(() =>
        {
            foreach (MyOneClass dg in Queue.GetConsumingEnumerable())
            {

                MyOtherClass vl = new MyOtherClass();
                vl.Id = dg.Id;
                vl.PerformTimeConsumingAction();

                OutputQueue.Add(vl);
            }
        });

代码 2：

Task loadingTask2 = Factory.StartNew(() =>
        {
            Parallel.ForEach(Queue.GetConsumingEnumerable(), (dg) =>
            {

                MyOtherClass vl = new MyOtherClass();
                vl.Id = dg.Id;
                vl.PerformTimeConsumingAction();

                OutputQueue.Add(vl);
            });
        });

使用 Console.Write 语句运行时的代码 1 似乎在等待上一个循环完成，直到它抓住下一个循环，但代码 2 确实并行处理多个元素。

我没有正确理解 Task.Action 中的常规 foreach 吗？我认为 .NET 会在负载保证的情况下为任务启动尽可能多的线程，并且 foreach 的每次迭代都将并行处理。

我还尝试将 PLINQ 结果传递给上述代码和观察者相同的行为：常规 foreach 似乎等待上一次迭代完成以开始下一次迭代，即使我使用了 .AsParallel() 和 .WithExecutionMode(ParallelExecutionMode.ForceParallelism)指令。

任何见解都将受到高度赞赏。 我知道 OrderingPartitioner 类，可以尝试使用它

Answer 1

一个常规的 foreach always 按顺序运行它的迭代。在某些情况下，没有魔法可以将其变成并行结构。这就像把你扔进pit of despair，因为这样就很难断言像 foreach 循环这样简单的东西的正确性。幸运的是，C# 的目标之一就是把你扔进成功的坑里：

如果您将 foreach 循环运行在单独的任务上，则所有迭代都会按顺序运行，但您可以在整个 foreach 中并行运行其他代码。

在单独的任务上执行常规 foreach 的流程如下所示：

              |
            __v_
           /    \
other code |    | foreach iteration 1
other code |    | foreach iteration 2
other code |    | foreach iteration 3
           ......
other code |    | foreach iteration n-1
other code |    | foreach iteration n
           v    v

Parallel.Foreach 的执行流程如下所示：

                  |
 _________________v________________
/    /    /    /    \    \    \    \
|1   |2   |3   |....|    |n-2 |n-1 |n
\____\____\____\____/____/____/____/
                  |
                  v

希望这有助于了解正在发生的事情。