在Task.WhenAll中完成任务时是否有回调

Question

假设我有以下内容:

IEnumerable<Task<TimeSpan>> tasks = //...
TimeSpan[] results = await Task.WhenAll(tasks);
// Handle results

当我能够处理结果时,所有任务必须完成.

有没有办法按需处理每个结果？

就像注册任务完成时将执行的委托/回调一样:

IEnumerable<Task<TimeSpan>> tasks = //...
await Task.WhenAll(tasks, result =>
{
   // A task has finished. This will get executed.
   // result is of type TimeSpan
});

Answer 1

有没有办法按需处理每个结果？

就像注册任务完成时将执行的委托/回调一样

是的,你只需稍微调整一下你的想法.

忘记注册回调(ContinueWith是一个危险的,极低级别的API).此外,您几乎不必完成任务.相反,在操作(任务)方面考虑您的问题.

现在,您有一系列返回的任务TimeSpan.该集合中的每个项目都是一个返回的操作TimeSpan.您真正想要做的是引入单个更高级操作的概念,等待原始操作完成然后执行您的操作后逻辑.

这正是async/ await适用于:

private static async Task<TimeSpan> HandleResultAsync(Task<TimeSpan> operation)
{
  var result = await operation;
  // A task has finished. This will get executed.
  // result is of type TimeSpan
  ...
  return result; // (assuming you want to propagate the result)
}

现在,您希望将此更高级别的操作应用于现有操作.LINQ Select是完美的:

IEnumerable<Task<TimeSpan>> tasks = ...
IEnumerable<Task<TimeSpan>> higherLevelTasks = tasks.Select(HandleResultAsync);

TimeSpan[] results = await Task.WhenAll(higherLevelTasks);
// By the time you get here, all results have been handled individually.

如果您不需要最终的结果集合,可以进一步简化:

private static async Task HandleResultAsync(Task<TimeSpan> operation)
{
  var result = await operation;
  // A task has finished. This will get executed.
  // result is of type TimeSpan
  ...
}

IEnumerable<Task<TimeSpan>> tasks = ...
IEnumerable<Task> higherLevelTasks = tasks.Select(HandleResultAsync);
await Task.WhenAll(higherLevelTasks);

Answer 2

有没有办法按需处理每个结果？

是的,您使用WhenAny而不是WhenAll......或致电ContinueWith每项任务.

例如,对于WhenAny方法:

ISet<Task<TimeSpan>> tasks = new HashSet<Task<TimeSpan>>(...);
while (tasks.Count != 0)
{
    var task = await Task.WhenAny(tasks);
    // Use task here
    tasks.Remove(task);
}

您可以使用另一个选项,将原始任务序列转换为按顺序完成的一系列任务,但给出相同的结果.详细信息在此博客文章中,但结果是您可以使用:

foreach (var task in tasks.InCompletionOrder())
{
    var result = await task;
    // Use the result
}