运行多个异步任务并等待它们全部完成

我需要在控制台应用程序中运行多个异步任务，并在进一步处理之前等待它们全部完成。

有很多文章，但我似乎越读越困惑。我已经阅读并理解了Task库的基本原理，但我显然在某个地方遗漏了一个链接。

我知道可以将任务串联起来，这样它们就可以在另一个任务完成后开始(这几乎是我读过的所有文章的场景)，但我希望所有任务同时运行，并且我想知道它们都完成后的情况。

对于这样的场景，最简单的实现是什么?

当前回答

应该有一个比公认的答案更简洁的解决方案。它不应该只用三步就能同时运行多个任务并获得结果。

创建任务等待Task.WhenAll(任务) 获取任务结果(例如task1.Result)

这里有一个方法，可以把这个问题简化为两个步骤:

    public async Task<Tuple<T1, T2>> WhenAllGeneric<T1, T2>(Task<T1> task1, Task<T2> task2)
    {
        await Task.WhenAll(task1, task2);
        return Tuple.Create(task1.Result, task2.Result);
    }

你可以这样使用它:

var taskResults = await Task.WhenAll(DoWorkAsync(), DoMoreWorkAsync());
var DoWorkResult = taskResults.Result.Item1;
var DoMoreWorkResult = taskResults.Result.Item2;

这样就不需要临时任务变量了。使用它的问题是，虽然它适用于两个任务，但您需要为三个任务或任何其他数量的任务更新它。而且，如果其中一个任务没有返回任何东西，它也不能很好地工作。实际上，.Net库应该提供一些可以做到这一点的东西

2020-08-14 15:48:28

其他回答

我所见过的最佳选择是以下扩展方法:

public static Task ForEachAsync<T>(this IEnumerable<T> sequence, Func<T, Task> action) {
    return Task.WhenAll(sequence.Select(action));
}

这样叫它:

await sequence.ForEachAsync(item => item.SomethingAsync(blah));

或者使用async lambda:

await sequence.ForEachAsync(async item => {
    var more = await GetMoreAsync(item);
    await more.FrobbleAsync();
});

2015-09-13 20:52:41

还有另一个答案……但我通常会遇到这样的情况，当我需要同时加载数据并将其放入变量中，比如:

var cats = new List<Cat>();
var dog = new Dog();

var loadDataTasks = new Task[]
{
    Task.Run(async () => cats = await LoadCatsAsync()),
    Task.Run(async () => dog = await LoadDogAsync())
};

try
{
    await Task.WhenAll(loadDataTasks);
}
catch (Exception ex)
{
    // handle exception
}

2018-10-17 11:53:04

这是我如何使用数组Func<>:

var tasks = new Func<Task>[]
{
   () => myAsyncWork1(),
   () => myAsyncWork2(),
   () => myAsyncWork3()
};

await Task.WhenAll(tasks.Select(task => task()).ToArray()); //Async    
Task.WaitAll(tasks.Select(task => task()).ToArray()); //Or use WaitAll for Sync

2017-05-23 11:30:08

如果你正在使用async/await模式，你可以像这样并行运行几个任务:

public async Task DoSeveralThings()
{
    // Start all the tasks
    Task first = DoFirstThingAsync();
    Task second = DoSecondThingAsync();

    // Then wait for them to complete
    var firstResult = await first;
    var secondResult = await second;
}

2021-08-03 11:41:48