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

Question

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

那里有很多文章,但我读的越多越好.我已经阅读并理解了Task库的基本原理,但我显然错过了某处的链接.

我知道可以将任务链接起来,以便它们在另一个完成之后开始(这几乎是我读过的所有文章的场景),但我希望我的所有任务同时运行,我想知道一次他们都完成了.

对于这样的场景,最简单的实现是什么？

Answer 1

这两个答案都没有提到等待的Task.WhenAll:

var task1 = DoWorkAsync();
var task2 = DoMoreWorkAsync();

await Task.WhenAll(task1, task2);

Task.WaitAll和之间的主要区别在于Task.WhenAll前者将阻塞(类似于Wait在单个任务上使用),而后者将不会并且可以等待,从而将控制权交还给调用者,直到所有任务完成.

更重要的是,异常处理不同:

Task.WaitAll:

至少有一个Task实例被取消 - 或者 - 在执行至少一个Task实例期间抛出了异常.如果任务被取消,则AggregateException在其InnerExceptions集合中包含OperationCanceledException.

Task.WhenAll:

如果任何提供的任务在故障状态下完成,则返回的任务也将在Faulted状态下完成,其中异常将包含来自每个提供的任务的一组未包装的异常的聚合.

如果所提供的任务都没有出现故障但至少其中一个被取消,则返回的任务将以"已取消"状态结束.

如果没有任何任务出现故障且没有任何任务被取消,则生成的任务将以RanToCompletion状态结束.如果提供的array/enumerable不包含任务,则返回的任务将在返回给调用者之前立即转换到RanToCompletion状态.

Answer 2

你可以创建许多任务,如:

List<Task> TaskList = new List<Task>();
foreach(...)
{
   var LastTask = new Task(SomeFunction);
   LastTask.Start();
   TaskList.Add(LastTask);
}

Task.WaitAll(TaskList.ToArray());

Answer 3

您可以使用WhenAll哪个将返回等待Task或WaitAll没有返回类型,并将阻止进一步的代码执行,Thread.Sleep直到所有任务完成,取消或出现故障.

例

var tasks = new Task[] {
    TaskOperationOne(),
    TaskOperationTwo()
};

Task.WaitAll(tasks);
// or
await Task.WhenAll(tasks);

如果你想以特定的顺序运行任务,你可以从这个 anwser 获得灵感.

Answer 4

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

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));

或者使用异步lambda:

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

Answer 5

你想链接Tasks,还是可以并行调用？

对于链接
只是做类似的事情

Task.Run(...).ContinueWith(...).ContinueWith(...).ContinueWith(...);
Task.Factory.StartNew(...).ContinueWith(...).ContinueWith(...).ContinueWith(...);

并且不要忘记检查Task每个实例中的前一个实例,ContinueWith因为它可能出现故障.

对于并行方式
我遇到的最简单的方法是:Parallel.Invoke 否则有Task.WaitAll或者你甚至可以用WaitHandles来做倒数零操作(等等,有一个新的类:) CountdownEvent,或者......

Answer 6

另一个答案......但我通常会发现自己处于一种情况，当我需要同时加载数据并将其放入变量时，例如：

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
}

Answer 7

这就是我使用数组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