.NET 爱好者！我刚刚偶然发现了一个非常酷的新 PR，它被合并到 .NET 运行时存储库中，我想分享一个例子。希望您能为新的 .NET 版本大肆宣传！在即将到来的 .NET 9 版本中，我们预计会有一个名为 .它在这里让您的异步编码冒险比以往任何时候都更流畅、更干净！Task.WhenEach

基本多任务处理

在管理多个异步任务（如发送电子邮件或执行一些数据库查询或计算）时，基本上是在执行之前准备的任何任务列表，通常有两个选项：

• Task.WhenAll：使用这种方法，您需要等待所有任务完成后再继续。这就像在开始派对之前等待所有朋友的到来——每个人都必须在乐趣开始之前到达那里。🎊
• Task.WhenAny：相反，允许您等待任何任务完成。这就像在聚会上盯着门，急切地等待下一位客人的到来。🚪👀WhenAny

那么，我们想要解决的问题是什么？

我们应该如何处理我们想要在任务结果完成后立即处理的情况？

以前，您需要持续监控任务，并在任务完成后立即处理它们。这涉及在循环的每次迭代中从列表中删除已完成的任务，以确保您始终准备好处理下一个完成的任务。

// Simulated download tasks
List<Task<int>> downloadTasks = [DownloadData1, DownloadData2, DownloadData3];

// Process tasks as they complete
while (downloadTasks.Any())
{
    Task<int> finishedTask = await Task.WhenAny(downloadTasks);
    downloadTasks.Remove(finishedTask);
    int result = await finishedTask;
    ProcessDataChunk(result);
}

正如你所看到的，这是一种相当笨拙的处理问题的方法，更不用说由于列表操作而成本高昂。

斯蒂芬·图布（Stephen Toub）在这篇非常古老但仍然相关的博客文章中提到了处理此类逻辑的其他一些方法：在任务完成时对其进行处理。

但是，嘿！不用再出汗了！随着 Microsoft 的新 .NET 9 API 合并到类中：WhenEachSystem.Threading.Tasks.Task

namespace System.Threading.Tasks;  
  
public class Task  
{  
   public static IAsyncEnumerable<Task> WhenEach(params Task[] tasks);  
   public static IAsyncEnumerable<Task> WhenEach(params ReadOnlySpan<Task> tasks); // params when possible  
   public static IAsyncEnumerable<Task> WhenEach(IEnumerable<Task> tasks);  
}

您可以以时尚的方式处理这些任务！

List<Task<int>> downloadTasks = [DownloadData1, DownloadData2, DownloadData3];  
  
await foreach (var finishedTask in Task.WhenEach(downloadTasks))  
{  
    ProcessDataChunk(await finishedTask);  
}

该方法返回一个 它允许你以与使用它来使用异步流类似的方式使用 - 这是在 .NET 8 中发布的。WhenEachIAsyncEnumerable await foreach

只需几行代码，我们就可以轻松完成相同的工作，采用更加_精简_和直观的异步编程方法！

我们应该如何处理任务取消处理？

PR 提出的一个直接问题是：我们现在应该如何处理在给定分配的时间内没有返回的任务？

两条很棒的评论

大卫·福勒

和 MihaZupan （Miha Zupan） （github.com） 为新添加的 API 构建了似乎是最佳实践的方法，使用简单的扩展方法并检查迭代中的取消。.WithCancellation

正如所评论的：

using var cts = new CancellationTokenSource(10_000);  
await foreach (var item in Task.WhenEach(connectionRequests).WithCancellation(cts.Token))  
{  
    // If TryReset fails, the timeout expired right after the last task completed.  
    if (!cts.TryReset()) cts.Token.ThrowIfCancellationRequested();  
  
    ProcessItem(item.Result);  
  
    cts.CancelAfter(10_000); // Start the timer again  
}

说明如何使用 集成取消逻辑。通过使用 ，开发人员可以有效地管理超时并优雅地响应取消请求，从而为异步工作流提供弹性和可靠性。Task.WhenEachCancellationTokenSource

奖金

3 年前在 dotnet/runtime Issue 中提到的一个很酷的提法：
AsyncEx — Stephen Cleary 的 async/await 帮助程序库，它具有一个名为的扩展方法，该方法返回将按顺序完成的包装任务的集合。OrderByCompletion

然后，为了实现类似的实现，它看起来像这样：

// declare WhenEach method  
async IAsyncEnumerable<T> WhenEach(Task<T>[] tasks) {  
  foreach (Task<T> task in tasks.OrderByCompletion())  
    yield return await task;  
  }  
}  
  
// example usage:  
await foreach (var task in WhenEach(downloadTasks))  
{  
  ProcessDataChunk()  
}

但是，正如 PR 中提到的，它的效率低于新的 BCL 实现，因为它为每次迭代分配一个新的，而不是在调用枚举器方法时在内部使用。TaskCompletionSourceAddCompletionActionMoveNext