.NET 9 即将推出的功能Task.WhenEach

程序笔记 2024年10月23日09:16 阅读(159)

.NET 爱好者！我刚刚偶然发现了一个非常酷的新 PR，它被合并到 .NET 运行时存储库中，我想分享一个例子。希望您能为新的 .NET 版本大肆宣传！在即将到来的 .NET 9 版本中，我们预计会有一个名为 .它在这里让您的异步编码冒险比以往任何时候都更流畅、更干净！Task.WhenEach基本多任务处理在管理多个异步任务（如发送电子邮件或执行一些数据库查询或计算）时，基本上是在执行之前准备的任何任务列表，通常有两个选项：Task.WhenAll：使用这种方法，您需要等待所有任务完成后再继续。

基本多任务处理

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

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

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