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 is a dangerous, extremely low-level 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);
}

您还可以使用另一个选项，将原始任务序列转换为按顺序完成但给出相同结果的任务序列。详情在this blog post，但结果是可以使用：

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