Parallel.ForEach和Foreach循环的TaskFactory.Tasks中BlockingCollection.GetConsumingEnumerable（）集合

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); 
      }); 
     }); 

代码1时Console.Write声明运行在每次迭代似乎在等待前一个周期完成下一个，直到它抓住一个，但Code 2并行处理多个元素。

我是不是无法正确理解Task.Action中的常规foreach？我认为.NET会像负载保证一样为任务启动多个线程，并且每个foreach迭代将被并行处理。

我也试过将PLINQ结果传递给上面的代码和观察者的相同行为：即使我已经使用了.AsParallel()和.WithExecutionMode(ParallelExecutionMode.ForceParallelism)指令，常规foreach似乎等待先前的迭代完成以启动下一个代码。

任何有识之士将不胜感激。 我知道OrderingPartitioner类，并可能尝试使用它

Answer 1

有规律的foreach 总是顺序运行其迭代。在某些情况下，没有什么魔法可以将它变成平行结构。这就像把你扔进pit of despair，因为那样很难断言像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 

希望帮助理解发生了什么。