平行的。ForEach vs Task.Factory.StartNew

下面的代码片段之间有什么区别?两者不都使用线程池线程吗?

例如，如果我想为集合中的每一项调用一个函数，

Parallel.ForEach<Item>(items, item => DoSomething(item));


vs


foreach(var item in items)
{
Task.Factory.StartNew(() => DoSomething(item));
}
145891 次浏览
小开
最佳答案

第一种是更好的选择。

平行的。ForEach在内部使用Partitioner<T>将集合分发到工作项中。它不会对每个项目执行一个任务，而是批量执行以降低所涉及的开销。

第二个选项将为集合中的每个项目安排一个Task。虽然结果(几乎)是相同的，但这会引入比必要的多得多的开销，特别是对于大型集合，并导致整体运行时变慢。

供您参考——如果需要的话，可以使用适当的重载到并行。ForEach来控制所使用的Partitioner。详情请参见MSDN上的自定义分割者。

在运行时，主要的区别在于第二种方式是异步的。这可以使用Parallel进行复制。通过做:

Task.Factory.StartNew( () => Parallel.ForEach<Item>(items, item => DoSomething(item)));

通过这样做，您仍然可以利用分区器，但是在操作完成之前不要阻塞。

小开
< p >平行。ForEach将优化(甚至可能不会启动新的线程)并阻塞，直到循环完成，而Task。Factory将为每个项目显式地创建一个新的任务实例，并在它们完成之前返回(异步任务)。 平行的。

小开

我做了一个小实验，用“Parallel”运行一个方法“1,000,000,000(10亿)次”。和一个带有“Task”对象的。

我测量了处理器时间，发现并行更有效。平行的。For将任务划分为小的工作项，并以最佳方式在所有核心上并行执行。在创建大量任务对象(供参考，TPL将在内部使用线程池)时，将移动每个任务的每次执行，从而在方框中产生更多压力，这从下面的实验中可以明显看出。

我还创建了一个小视频，解释了基本的TPL，并演示了如何并行。与正常的任务和线程相比，更有效地利用你的核心http://www.youtube.com/watch?v=No7QqSc5cl8。

实验1

Parallel.For(0, 1000000000, x => Method1());

实验2

for (int i = 0; i < 1000000000; i++)
{
Task o = new Task(Method1);
o.Start();
}

处理器时间比较

小开

在我看来，最现实的情况是当任务需要完成繁重的操作时。Shivprasad的方法更多地关注对象创建/内存分配，而不是计算本身。我做了一个研究，调用以下方法:

public static double SumRootN(int root)
{
double result = 0;
for (int i = 1; i < 10000000; i++)
{
result += Math.Exp(Math.Log(i) / root);
}
return result;
}

这个方法的执行大约需要0.5秒。

我用Parallel调用了200次:

Parallel.For(0, 200, (int i) =>
{
SumRootN(10);
});

然后我用传统的方式调用了200次:

List<Task> tasks = new List<Task>() ;
for (int i = 0; i < loopCounter; i++)
{
Task t = new Task(() => SumRootN(10));
t.Start();
tasks.Add(t);
}


Task.WaitAll(tasks.ToArray());

第一个案例在26656毫秒内完成，第二个案例在24478毫秒内完成。我重复了很多次。每次第二种方法都要快一点。


提交答案