如何在不等待的情况下等待异步操作的结果？

Question

void A()
{
    foreach (var document in documents)
    {
       var res = records.BulkWriteAsync(operationList, writeOptions); // res is Task<BulkWriteResult<JobInfoRecord>>
    }
}

foreach之后我想等待所有BulkWriteAsync的结果，怎么办？我不想将A() 标记为async 并执行以下操作

await records.BulkWriteAsync(operationList, writeOptions);

这是好的解决方案吗？

void A()
{
var tasks = new List<Task<BulkWriteResult<JobInfoRecord>>>();

foreach (var document in documents)
{
     var task = records.BulkWriteAsync(operationList, writeOptions);
     tasks.Add(task);
}

Task.WaitAll(tasks.ToArray());
}

如果我将public async void A() 标记为async，我将在try catch 中调用A() 我永远不会在catch 中

Answer 1

嗯，首先你需要一个代表所有操作的Task。最简单的方法是使用一些 LINQ：

Task.WhenAll(documents.Select(i => records.BulkWriteAsync(...)));

然后，理想情况下，您希望await 该任务。如果不行，你可以试试

task.GetAwaiter().GetResult();

但是，请确保所有任务都没有线程亲和性 - 这是获得死锁的好方法。在 UI 线程上等待任务而任务本身需要 UI 线程就是一个典型的例子。

await 的全部意义在于它允许您像处理同步代码一样处理异步代码。所以从外面看，你似乎从未离开过方法，直到你真正到达return（或方法的结尾）。但是，要使其正常工作，您的方法必须返回 Task（或 Task<T>），而被调用者必须依次返回 await 您的方法。

这样的代码：

try
{
  tasks = Task.WhenAll(documents.Select(i => ...));

  await tasks;
}
catch (Exception ex)
{
  // Handle the exception
}

看起来会完全同步运行，并且所有异常都将照常处理（尽管因为我们使用的是Task.WhenAll，所以有些异常会被包裹在AggregateException中）。

然而，这实际上是不可能用 .NET 和 C# 的构建方式来处理的，所以 C# 编译器作弊 - await 基本上是一个 return，它可以保证你会得到的结果将来。发生这种情况时，控件将返回到 await 上次离开的位置。 Task 就是这样的承诺——如果你使用 async void，被调用者无法知道发生了什么，它别无选择，只能继续，就好像异步方法是一个运行后忘记的方法一样。如果你使用async Task，你可以await异步方法和一切“感觉”再次同步。不要断链，错觉就是完美的:)