C# 怎么使用 Task.WhenAll 并行执行多个任务_C# Task.WhenAll 并行任务执行教程

Task.WhenAll用于并行执行多个独立任务,显著提升I/O密集型操作效率。示例中三个延迟任务并行运行,总耗时约1秒,而非串行的2.3秒;异常处理需注意,仅捕获首个异常,需遍历任务检查全部错误;结合LINQ可动态发起多个HTTP请求,并汇总结果。关键在于确保任务无依赖、可独立运行。

c# 怎么使用 task.whenall 并行执行多个任务_c# task.whenall 并行任务执行教程

Task.WhenAll 是 C# 中用于并行执行多个任务的核心方法之一。它能等待所有提供的任务完成,并返回一个组合任务,该任务在所有输入任务都完成后才结束。相比串行执行,使用 Task.WhenAll 可显著提升程序效率,尤其适用于 I/O 密集型操作(如网络请求、文件读写)或可并行处理的计算任务。

何时使用 Task.WhenAll

当你有一组独立的任务需要运行,并希望它们同时开始、并行执行,最后统一获取结果时,Task.WhenAll 是理想选择。常见场景包括:

调用多个 Web API 获取数据从多个数据库查询记录并发读取多个文件触发多个异步服务调用

这些任务如果逐个执行会浪费等待时间,而并行处理可以缩短整体耗时。

基本用法示例

以下是一个简单示例,演示如何使用 Task.WhenAll 并行执行三个延迟任务:

using System;using System.Threading.Tasks;

class Program{static async Task Main(string[] args){var task1 = DelayAndReturn(1, 1000);var task2 = DelayAndReturn(2, 500);var task3 = DelayAndReturn(3, 800);

    // 并行执行所有任务,等待全部完成    var results = await Task.WhenAll(task1, task2, task3);    foreach (var result in results)    {        Console.WriteLine($"任务返回值: {result}");    }}static async Task DelayAndReturn(int value, int delayMs){    await Task.Delay(delayMs); // 模拟异步工作    return value;}

}

输出结果为:

任务返回值: 1任务返回值: 2任务返回值: 3

尽管任务按顺序定义,但它们是并行启动的,总耗时约为最长的那个任务(约 1 秒),而不是三者相加(2.3 秒)。

处理异常与错误传播

Task.WhenAll 在任一任务抛出异常时也会完成,但异常会被封装在返回的 Task 中。你可以通过检查任务状态或使用 try-catch 捕获:

try{    var task1 = Task.Run(() => { throw new Exception("任务1失败"); });    var task2 = Task.Delay(100);    var task3 = Task.FromResult(42);
await Task.WhenAll(task1, task2, task3);

}catch (Exception ex){Console.WriteLine($"捕获异常: {ex.Message}");}

注意:即使多个任务失败,你也只能捕获第一个被观察到的异常。若要收集所有任务的异常信息,建议分别检查每个任务的状态:

var tasks = new[]{    Task.Run(() => { throw new Exception("错误1"); }),    Task.Run(() => { throw new Exception("错误2"); }),    Task.Delay(100)};

await Task.WhenAll(tasks);

// 检查每个任务是否出错foreach (var t in tasks){if (t.IsFaulted){Console.WriteLine($"任务异常: {t.Exception?.InnerExceptions[0].Message}");}}

结合集合动态创建并行任务

实际开发中,任务数量可能是动态的。可以结合 LINQ 或循环生成任务列表:

var urls = new[] { "http://api1.com", "http://api2.com", "http://api3.com" };

var tasks = urls.Select(async url =>{using var client = new HttpClient();var response = await client.GetStringAsync(url);return response.Length;});

var lengths = await Task.WhenAll(tasks);

Console.WriteLine($"各响应长度: {string.Join(", ", lengths)}");

这段代码会并行发起多个 HTTP 请求,最后汇总结果。

基本上就这些。合理使用 Task.WhenAll 能有效提升异步程序性能,关键是确保任务之间无依赖、可独立运行。不复杂但容易忽略。

以上就是C# 怎么使用 Task.WhenAll 并行执行多个任务_C# Task.WhenAll 并行任务执行教程的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1441573.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年12月17日 18:13:26
下一篇 2025年12月13日 05:13:11

相关推荐

发表回复

登录后才能评论
关注微信