foreach 循环迭代中的多个 async/await 调用

Question

我正在努力思考如何在 foreach 循环中处理多个 async/await 调用。我有大约 20,000 行由 foreach 循环处理的数据。我的代码大致是：

foreach (var item in data)
{
    if (ConditionA(item))
    {
        if (ConditionAB(item));
        {
            await CreateThingViaAPICall(item)
        }
        else
        {
            var result = await GetExistingRecord(item);
            var result2 = await GetOtherExistingRecord(result);
            var result3 = await GetOtherExistingRecord(result2);
            //Do processing
            ...           
            await CreateThingViaAPICall();
        }
    }
    ... and so on        
}

我看到很多帖子说在循环中使用异步的最佳方法是构建任务列表，然后使用 Task.WhenAll。在我的情况下，作为每次迭代的一部分，我有相互依赖的任务。在这种情况下，如何建立要执行的任务列表？

Answer 1

如果您将单个项目的处理分解为单独的（异步）方法，这是最简单的：

private async Task ProcessItemAsync(Item item)
{
    if (ConditionA(item))
    {
        if (ConditionAB(item));
        {
            await CreateThingViaAPICall(item)
        }
        else
        {
            var result = await GetExistingRecord(item);
            var result2 = await GetOtherExistingRecord(result);
            var result3 = await GetOtherExistingRecord(result2);
            //Do processing
            ...           
            await CreateThingViaAPICall();
        }
    }
    ... and so on
}

然后像这样处理您的收藏：

var tasks = data.Select(ProcessItemAsync);
await Task.WhenAll(tasks);

这有效地将处理单个项目所需的多个相关任务包装到一个任务中，允许这些步骤按顺序发生，同时同时处理集合本身的项目。

对于成千上万个项目，您可能会出于各种原因发现需要限制并发运行的任务数。查看此类场景的 TPL 数据流。有关示例，请参阅here。

Answer 2

如果我没记错的话，在 foreach 中使用 async/wait 的推荐方法是先构建一个任务列表，然后调用 Task.WhenAll。

你错了。

如果您有多个不依赖于彼此的任务，那么将这些多个任务发生在WhenAll 中确实是一个非常好的主意，这样它们就可以安排在一起，从而提供更好的吞吐量。

但是，如果每个任务都依赖于前一个任务的结果，那么这种方法是不可行的。相反，您应该只在 foreach 中使用 await 它们。

确实，这在任何情况下都可以正常工作，如果不需要，让任务相互等待只是次优的。

await 在foreach 中执行任务的能力实际上是async/await 给我们带来的最大收获之一。大多数使用await 的代码都可以很容易地重写为使用ContinueWith，虽然不那么优雅，但是循环更棘手，如果循环的实际结束只能通过检查任务本身的结果来找到，那就更棘手了.