Parallel.ForEach vs Task.Run和Task.WhenAll
Parallel.ForEach vs Task.Run和Task.WhenAll
提问于 2013-10-01 04:13:07
使用Parallel.ForEach或Task.Run()异步启动一组任务有什么区别？
版本1：
List<string> strings = new List<string> { "s1", "s2", "s3" };
Parallel.ForEach(strings, s =>
{
DoSomething(s);
});版本2：
List<string> strings = new List<string> { "s1", "s2", "s3" };
List<Task> Tasks = new List<Task>();
foreach (var s in strings)
{
Tasks.Add(Task.Run(() => DoSomething(s)));
}
await Task.WhenAll(Tasks);回答 4
Stack Overflow用户
回答已采纳
发布于 2013-10-01 04:17:36
在这种情况下，第二个方法将异步等待任务完成，而不是阻塞。
然而，在循环中使用Task.Run有一个缺点--使用Parallel.ForEach时，会创建一个Partitioner，以避免创建更多不必要的任务。Task.Run将始终为每个项创建一个任务(因为您正在这样做)，但是Parallel类批处理工作，因此您创建的任务少于工作项总数。这可以提供明显更好的整体性能，特别是如果循环体每个项目的工作量很小的话。
如果是这种情况，您可以通过编写以下代码来组合这两个选项：
await Task.Run(() => Parallel.ForEach(strings, s =>
{
DoSomething(s);
}));请注意，这也可以用以下较短的形式编写：
await Task.Run(() => Parallel.ForEach(strings, DoSomething));Stack Overflow用户
发布于 2013-10-01 04:15:05
第一个版本将同步阻塞调用线程(并在其上运行一些任务)。
如果它是一个UI线程，这将冻结UI。
第二个版本将在线程池中异步运行任务，并释放调用线程，直到它们完成。
使用的调度算法也存在差异。
请注意，您的第二个示例可以缩短为
await Task.WhenAll(strings.Select(s => Task.Run(() => DoSomething(s))));Stack Overflow用户
发布于 2019-07-18 08:54:06
我见过Parallel.ForEach使用不当，我想这个问题中的一个例子会有所帮助。
当您在控制台应用程序中运行以下代码时，您将看到在Parallel.ForEach中执行的任务如何不会阻塞调用线程。如果你不关心结果(正的或负的)，这是可以的，但是如果你确实需要结果，你应该确保使用Task.WhenAll。
using System;
using System.Linq;
using System.Threading.Tasks;
namespace ParrellelEachExample
{
class Program
{
static void Main(string[] args)
{
var indexes = new int[] { 1, 2, 3 };
RunExample((prefix) => Parallel.ForEach(indexes, (i) => DoSomethingAsync(i, prefix)),
"Parallel.Foreach");
Console.ForegroundColor = ConsoleColor.Yellow;
Console.WriteLine("*You'll notice the tasks haven't run yet, because the main thread was not blocked*");
Console.WriteLine("Press any key to start the next example...");
Console.ReadKey();
RunExample((prefix) => Task.WhenAll(indexes.Select(i => DoSomethingAsync(i, prefix)).ToArray()).Wait(),
"Task.WhenAll");
Console.WriteLine("All tasks are done. Press any key to close...");
Console.ReadKey();
}
static void RunExample(Action<string> action, string prefix)
{
Console.ForegroundColor = ConsoleColor.White;
Console.WriteLine($"{Environment.NewLine}Starting '{prefix}'...");
action(prefix);
Console.WriteLine($"{Environment.NewLine}Finished '{prefix}'{Environment.NewLine}");
}
static async Task DoSomethingAsync(int i, string prefix)
{
await Task.Delay(i * 1000);
Console.WriteLine($"Finished: {prefix}[{i}]");
}
}
}结果如下：
结论：
将Parallel.ForEach与任务一起使用不会阻塞调用线程。如果你关心结果，请确保等待任务。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/19102966
复制相关文章
相似问题
腾讯云开发者
