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

Question

我对这两个循环进行了实验，并注意到即使任务的 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 总是按顺序运行其迭代。在某些情况下，没有什么魔法可以将其变成并行结构。这就像把你扔进 坑绝望，因为这样就很难断言像 foreach 循环这样简单的东西的正确性。幸运的是，C# 的目标之一就是把你扔进成功的深渊：

任务上，则所有迭代都会按顺序运行，但您可以与整个 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

希望有助于理解正在发生的情况。