如何使用 LINQ 异步等待任务列表？

Question

我有一个这样创建的任务列表：

public async Task<IList<Foo>> GetFoosAndDoSomethingAsync()
{
    var foos = await GetFoosAsync();

    var tasks = foos.Select(async foo => await DoSomethingAsync(foo)).ToList();

    ...
}

通过使用.ToList()，任务应该全部启动。现在我想等待他们完成并返回结果。

这适用于上述... 块：

var list = new List<Foo>();
foreach (var task in tasks)
    list.Add(await task);
return list;

它可以满足我的要求，但这似乎很笨拙。我宁愿写一些像这样更简单的东西：

return tasks.Select(async task => await task).ToList();

... 但这不会编译。我错过了什么？还是不能这样表达？

Answer 1

Task.WhenAll 的一个问题是它会产生并行性。在大多数情况下，它可能会更好，但有时你想避免它。例如，从 DB 中批量读取数据并将数据发送到某个远程 Web 服务。您不想将所有批次加载到内存中，而是在处理前一个批次后访问数据库。所以，你必须打破异步性。这是一个例子：

var events = Enumerable.Range(0, totalCount/ batchSize)
   .Select(x => x*batchSize)
   .Select(x => dbRepository.GetEventsBatch(x, batchSize).GetAwaiter().GetResult())
   .SelectMany(x => x);
foreach (var carEvent in events)
{
}

注意.GetAwaiter().GetResult() 将其转换为同步。只有在 batchSize of events 被处理后，DB 才会被延迟命中。

Answer 2

在斯蒂芬的answer上展开也可以不用.ToList()表示如下：

var tasks = foos.Select(aFoo => aFoo.DoSomething());
await Task.WhenAll(tasks).ConfigureAwait(true);

背景：在某些情况下，调用.ToList() 可能会导致当时执行的副作用，因为随后枚举了可枚举。如果可枚举是对一组 API 或一组查询的调用，那么这可能不是当时所期望的行为。如果没有.ToList()，将在任务等待时枚举枚举。

更具体地说：使用 (Fluent) NHibernate，您通常会避免在查询中使用.ToList()，否则您最终可能会读取整个结果集。这可能是您想要的更多数据。

Answer 3

为了扩展斯蒂芬的回答，我创建了以下扩展方法来保留 LINQ 的 fluent style。然后你可以做

await someTasks.WhenAll()

namespace System.Linq
{
    public static class IEnumerableExtensions
    {
        public static Task<T[]> WhenAll<T>(this IEnumerable<Task<T>> source)
        {
            return Task.WhenAll(source);
        }
    }
}

Answer 4

LINQ 不适用于async 代码，但您可以这样做：

var tasks = foos.Select(DoSomethingAsync).ToList();
await Task.WhenAll(tasks);

如果您的任务都返回相同类型的值，那么您甚至可以这样做：

var results = await Task.WhenAll(tasks);

这是相当不错的。 WhenAll返回一个数组，所以我相信你的方法可以直接返回结果：

return await Task.WhenAll(tasks);

Answer 5

Task.WhenAll 应该在这里解决问题。

Answer 6

使用Task.WaitAll 或Task.WhenAll 中合适的那个。