如果我不关心任务完成的顺序,只需要它们全部完成,我是否还应该使用 await Task.WhenAll
而不是多个 await
?例如,DoWork2
是否低于 DoWork1
的首选方法(为什么?):
using System;
using System.Threading.Tasks;
namespace ConsoleApp
{
class Program
{
static async Task<string> DoTaskAsync(string name, int timeout)
{
var start = DateTime.Now;
Console.WriteLine("Enter {0}, {1}", name, timeout);
await Task.Delay(timeout);
Console.WriteLine("Exit {0}, {1}", name, (DateTime.Now - start).TotalMilliseconds);
return name;
}
static async Task DoWork1()
{
var t1 = DoTaskAsync("t1.1", 3000);
var t2 = DoTaskAsync("t1.2", 2000);
var t3 = DoTaskAsync("t1.3", 1000);
await t1; await t2; await t3;
Console.WriteLine("DoWork1 results: {0}", String.Join(", ", t1.Result, t2.Result, t3.Result));
}
static async Task DoWork2()
{
var t1 = DoTaskAsync("t2.1", 3000);
var t2 = DoTaskAsync("t2.2", 2000);
var t3 = DoTaskAsync("t2.3", 1000);
await Task.WhenAll(t1, t2, t3);
Console.WriteLine("DoWork2 results: {0}", String.Join(", ", t1.Result, t2.Result, t3.Result));
}
static void Main(string[] args)
{
Task.WhenAll(DoWork1(), DoWork2()).Wait();
}
}
}
await t1; await t2; ....; await tn
=>在这两种情况下,第二个始终是最佳选择
是的,请使用 WhenAll
,因为它会同时传播所有错误。使用多个等待,如果前面的等待之一抛出,您将丢失错误。
另一个重要区别是,WhenAll
将等待所有任务完成即使出现故障(故障或取消的任务)。按顺序手动等待会导致意外的并发,因为您的程序中想要等待的部分实际上会提前继续。
我认为这也使阅读代码更容易,因为您想要的语义直接记录在代码中。
我的理解是,更喜欢 Task.WhenAll
而不是多个 await
的主要原因是性能/任务“搅动”:DoWork1
方法执行以下操作:
从给定的上下文开始
保存上下文
等待t1
恢复原始上下文
保存上下文
等t2
恢复原始上下文
保存上下文
等t3
恢复原始上下文
相比之下,DoWork2
这样做:
从给定的上下文开始
保存上下文
等待所有 t1、t2 和 t3
恢复原始上下文
当然,对于您的特定情况,这是否足够大是“取决于上下文”(请原谅双关语)。
异步方法被实现为状态机。可以编写方法使它们不被编译到状态机中,这通常被称为快速通道异步方法。这些可以像这样实现:
public Task DoSomethingAsync()
{
return DoSomethingElseAsync();
}
使用 Task.WhenAll
时,可以维护此快速跟踪代码,同时仍确保调用者能够等待所有任务完成,例如:
public Task DoSomethingAsync()
{
var t1 = DoTaskAsync("t2.1", 3000);
var t2 = DoTaskAsync("t2.2", 2000);
var t3 = DoTaskAsync("t2.3", 1000);
return Task.WhenAll(t1, t2, t3);
}
(免责声明:此答案取自/启发自 Ian Griffiths 在 Pluralsight 上的 TPL Async 课程)
更喜欢WhenAll 的另一个原因是异常处理。
假设您的 DoWork 方法上有一个 try-catch 块,并且假设它们正在调用不同的 DoTask 方法:
static async Task DoWork1() // modified with try-catch
{
try
{
var t1 = DoTask1Async("t1.1", 3000);
var t2 = DoTask2Async("t1.2", 2000);
var t3 = DoTask3Async("t1.3", 1000);
await t1; await t2; await t3;
Console.WriteLine("DoWork1 results: {0}", String.Join(", ", t1.Result, t2.Result, t3.Result));
}
catch (Exception x)
{
// ...
}
}
在这种情况下,如果所有 3 个任务都抛出异常,则只会捕获第一个。以后的任何异常都将丢失。即如果 t2 和 t3 抛出异常,只有 t2 会被捕获;等后续任务异常将不会被观察到。
在 WhenAll 中 - 如果任何或所有任务出错,则生成的任务将包含所有异常。 await 关键字仍然总是重新抛出第一个异常。因此,其他异常仍然有效地未被观察到。解决这个问题的一种方法是在 WhenAll 任务之后添加一个空的延续并将 await 放在那里。这样,如果任务失败,结果属性将抛出完整的聚合异常:
static async Task DoWork2() //modified to catch all exceptions
{
try
{
var t1 = DoTask1Async("t1.1", 3000);
var t2 = DoTask2Async("t1.2", 2000);
var t3 = DoTask3Async("t1.3", 1000);
var t = Task.WhenAll(t1, t2, t3);
await t.ContinueWith(x => { });
Console.WriteLine("DoWork1 results: {0}", String.Join(", ", t.Result[0], t.Result[1], t.Result[2]));
}
catch (Exception x)
{
// ...
}
}
此问题的其他答案提供了首选 await Task.WhenAll(t1, t2, t3);
的技术原因。这个答案旨在从更温和的方面(@usr 暗示)来看待它,同时仍然得出相同的结论。
await Task.WhenAll(t1, t2, t3);
是一种更实用的方法,因为它声明了意图并且是原子的。
使用 await t1; await t2; await t3;
,没有什么可以阻止队友(甚至可能是您未来的自己!)在各个 await
语句之间添加代码。当然,您已将其压缩为一行以从根本上实现这一目标,但这并不能解决问题。此外,在团队环境中,在给定的代码行中包含多个语句通常是一种不好的形式,因为它会使源文件更难被人眼扫描。
简而言之,await Task.WhenAll(t1, t2, t3);
更易于维护,因为它更清楚地传达了您的意图,并且不太容易受到来自善意代码更新甚至只是合并出错的特殊错误的影响。
就这么简单。
如果您对外部 api 或数据库有多个 http 调用 IEnumerable
,请使用 WhenAll
并行执行请求,而不是等待单个调用完成然后继续其他调用。
不定期副业成功案例分享
await
其结果则不会。