在.NET中,WhenAll 是一个与异步编程相关的扩展方法,它属于 System.Threading.Tasks 命名空间下的 TaskExtensions 类。这个方法主要用于处理一组 Task 对象,并等待它们全部完成。当所有任务都完成时,WhenAll 将返回一个包含所有任务结果的 Task<Task[]> 对象。
解释
WhenAll 方法用于并行执行多个异步任务,并等待它们全部完成。这有助于简化异步编程模型,特别是当你有多个独立的任务需要并行执行,并且你希望等待它们全部完成后再继续执行后续代码时。
用法
下面是一个使用 WhenAll 的简单示例:
using System; using System.Threading.Tasks; class Program { static async Task Main(string[] args) { // 创建三个异步任务 Task task1 = Task.Run(() => DoSomethingAsync("Task 1")); Task task2 = Task.Run(() => DoSomethingAsync("Task 2")); Task task3 = Task.Run(() => DoSomethingAsync("Task 3")); // 使用 WhenAll 等待所有任务完成 Task[] tasks = { task1, task2, task3 }; await Task.WhenAll(tasks); Console.WriteLine("All tasks are completed."); } static async Task DoSomethingAsync(string taskName) { Console.WriteLine($"Starting {taskName}..."); await Task.Delay(1000); // 模拟耗时操作 Console.WriteLine($"Completed {taskName}."); } }
在上面的示例中,我们创建了三个异步任务 task1、task2 和 task3,每个任务都调用 DoSomethingAsync 方法来模拟一些异步操作。然后,我们使用 Task.WhenAll(tasks) 来等待所有任务完成。当所有任务都完成时,程序将输出 "All tasks are completed."。
注意,WhenAll 不会返回任何任务的结果。如果你需要访问每个任务的结果,你可以使用 Task.WhenAll 的一个重载版本,它返回一个 Task<TResult[]> 对象,其中 TResult 是任务返回值的类型。例如,如果每个任务都返回一个 int 值,那么 Task.WhenAll 将返回一个 Task<int[]> 对象。
注意事项
WhenAll 不会取消任何任务。如果你需要取消一组任务,你需要单独处理每个任务的取消逻辑。
如果其中一个任务抛出异常,WhenAll 会等待所有其他任务完成,然后抛出一个 AggregateException,其中包含所有任务的异常。这意味着即使有任务失败,WhenAll 也会继续等待其他任务完成。
WhenAll 返回一个任务,你可以使用 await 关键字等待它完成。在等待期间,不会阻塞调用线程,这有助于提高应用程序的响应性和性能。
扩展:WaitAll 和 WhenAll 的使用及区别
用过.net 异步编程的同学都知道,比以前的多线程编程实现起来真的方便很多,今天把WaitAll和WhenAll这两种编程方式回顾总结一下(当然WaitAny、WhenAny是一样的操作)
1:WaitAll
这个方法在我理解看来,主要是为了解决多个不太相关的操作同步执行的话,耗时较多,这个方法可以使得他们异步同时执行,然后当所有操作都完成以后,再去进行接下来的操作,talk is cheap,show you code!
举个例子:
var response1 = new PriceDataResponse(); var response2 = new PriceDataResponse(); //定义两个异步任务 task1,task2 Task task1 = Task.Factory.StartNew(() => { response1 = SampleFunc(1); }); Task task2 = Task.Factory.StartNew(() => { response2 = SampleFunc(2); }); //等待两个任务执行完成(同时执行) Task.WaitAll(task1, task2); //执行完以后,再进行以下操作 if (response1.Prices.Any()) { return response1; } if (response2.Prices.Any()) { return response2; }
也就是说,task1 和 task2 两个任务在定义之后就已经马不停蹄的在子线程中运行了,Task.WaitAll 是一个等待的过程,参数就是Task参数,一旦全部执行完毕了,就继续往下执行,这里是阻塞的,还是比较好理解的。
这样的话WaitAny就很好理解了,就是参数里面的Task 有任意一个执行完成,就继续执行后面的逻辑
2:WhenAll
WhenAll其实跟WaitAll是为了实现一样的功能,只是在WaitAll基础上又做了一层包装,看代码就明白了
var response1 = new PriceDataResponse(); var response2 = new PriceDataResponse(); //定义两个异步任务 task1,task2 Task task1 = Task.Factory.StartNew(() => { response1 = SampleFunc(1); }); Task task2 = Task.Factory.StartNew(() => { response2 = SampleFunc(2); }); //等待两个任务执行完成(同时执行) Task.WhenAll(task1, task2).ContinueWith(p => { if (response1.Prices.Any()) { return response1; } if (response2.Prices.Any()) { return response2; } return null; }, TaskContinuationOptions.OnlyOnRanToCompletion);
功能上与WaitAll 是一样,意思就是在两个异步结束了以后,再继续做 ContinueWith 里面的处理这里的 p 相当于是Task,如果前面定义的Task有返回值,那么这里可以用p.Result来取值
WhenAny 是一样的,任意一个完成就执行后面代码