等待一系列任务按顺序运行

Question

我想创建一个通用方法来等待一系列任务按顺序完成，检索每个任务的结果。这是我创建的代码：

public static class TaskMixin 
{
    public static async Task<IEnumerable<T>> AwaitAll<T>(this IEnumerable<Task<T>> tasks)
    {
        var results = new List<T>();
        foreach (var t in tasks)
        {
            results.Add(await t);
        }

        return results;
    }
}

有更好的或内置的方法吗？

通知

在编写上述方法之前，我尝试过使用内置的Task.WhenAll 方法，但这给我带来了麻烦，因为这些任务使用的是实体框架的DbContext，而且它们似乎是同时运行的。

这是我使用Task.WhenAll时遇到的异常。

第二个操作在前一个上下文之前开始 异步操作完成

Answer 1

无法确保传递给此方法的任务尚未运行，实际上它们可能已经启动了热任务。如果任务已经在运行，那么您只需按顺序等待它们。如果您希望操作按顺序运行，那么您需要调用按顺序返回任务的方法。

或者对于 EF 的 DbContext，通常最好为每个请求使用一个新的 DbContext。但是，如果您执行许多并行查询，那么您可能会以错误的方式解决问题。许多并行查询并不一定意味着您的查询会运行得更快。

但是，您可以通过像这样获取Func<Task<T>> 委托来按顺序抽象出正在运行的操作：

public async Task<IEnumerable<T>> RunSequentiallyAsync<T>(Func<Task<T>>[] operations)
{
    var results = new List<T>();
    foreach (var op in operations)
    {
        results.Add(await op());
    }
    return results;
}

Answer 2

按顺序等待任务的另一种方法是使用 IAsyncEnumerable 和 await foreach 语法。

这里是一个示例扩展方法和一个使用它的控制台应用程序。控制台应用程序反转任务以证明这些任务确实是按顺序调用的。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace SO60066033
{
    public class Program
    {
        static async Task Main(string[] args)
        {
            var someTasks = new Func<Task<int>>[]
            {
                () => Task.FromResult(1),
                () => Task.FromResult(2),
                () => Task.FromResult(3),
                () => Task.FromResult(4),
            };
            var results = someTasks.AwaitAll();
            await foreach (var result in results)
                Console.WriteLine(result);
            var reversedTasks = someTasks.Reverse().ToList();
            var reversedResults = reversedTasks.AwaitAll();
            await foreach (var result in reversedResults)
                Console.WriteLine(result);
        }
    }
    public static class TaskExtensions
    {
        public static async IAsyncEnumerable<T> AwaitAll<T>(this IEnumerable<Func<Task<T>>> tasks)
        {
            foreach (var task in tasks)
                yield return await task();
        }
    }
}