在.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 是一样的,任意一个完成就执行后面代码

到此这篇关于.Net 中WhenAll的解释和用法的文章就介绍到这了,更多相关.Net WhenAll用法内容请搜索本站以前的文章或继续浏览下面的相关文章希望大家以后多多支持本站!

点赞(0) 打赏

评论列表 共有 0 条评论

暂无评论

微信公众账号

微信扫一扫加关注

发表
评论
返回
顶部