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

假设我有以下内容：

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

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

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

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

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

Answer 1

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

是的，您使用WhenAny而不是WhenAll …或者在每个任务上调用ContinueWith 。

例如，对于WhenAny方法：

 ISet> tasks = new HashSet>(...); 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 } 

Answer 2

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

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

是的，你只需稍微调整一下你的想法。

忘记注册回调（ ContinueWith是一个危险的，极低级别的API ）。 此外，您几乎不必完成任务。 相反，请考虑操作 （任务）方面的问题。

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

这正是async / await的用途：

 private static async Task HandleResultAsync(Task 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> tasks = ... IEnumerable> 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 operation) { var result = await operation; // A task has finished. This will get executed. // result is of type TimeSpan ... } IEnumerable> tasks = ... IEnumerable higherLevelTasks = tasks.Select(HandleResultAsync); await Task.WhenAll(higherLevelTasks);