TaskFactory.Tasks中的BlockingCollection.GetConsumingEnumerable（）集合的Parallel.ForEach和foreach循环
|
我已经对这两个循环进行了实验，发现即使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);
}
});
Task loadingTask2 = Factory.StartNew(() =>
{
Parallel.ForEach(Queue.GetConsumingEnumerable(), (dg) =>
{
MyOtherClass vl = new MyOtherClass();
vl.Id = dg.Id;
vl.PerformTimeConsumingAction();
OutputQueue.Add(vl);
});
});
.AsParallel()
.WithExecutionMode(ParallelExecutionMode.ForceParallelism)
没有找到相关结果
已邀请:
1 个回复
癸痊醒
| __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的执行流程如下所示：| _________________v________________ / / / / \\ \\ \\ \\ |1 |2 |3 |....| |n-2 |n-1 |n \\____\\____\\____\\____/____/____/____/ | v