处理异步并行任务的多个异常

Problem

多个任务并行运行，所有任务、没有任务或其中任何任务都可能抛出异常。当所有任务完成后，必须报告所有可能发生的异常（通过日志、电子邮件、控制台输出......等等）。

预期行为

我可以通过 linq 使用异步 lambda 构建所有任务，然后等待它们与Task.WhenAll(tasks)。然后我就可以抓住一个AggregateException并报告每个单独的内部异常。

实际行为

An AggregateException被抛出，但它只包含一个内部异常，无论抛出了多少个单独的异常。

最小完整可验证示例

static void Main(string[] args)
{
    try
    {
        ThrowSeveralExceptionsAsync(5).Wait();
    }
    catch (AggregateException ex)
    {
        ex.Handle(innerEx =>
        {
            Console.WriteLine($"\"{innerEx.Message}\" was thrown");
            return true;
        });
    }

    Console.ReadLine();
}

private static async Task ThrowSeveralExceptionsAsync(int nExceptions)
{
    var tasks = Enumerable.Range(0, nExceptions)
        .Select(async n =>
        {
            await ThrowAsync(new Exception($"Exception #{n}"));
        });

    await Task.WhenAll(tasks);
}

private static async Task ThrowAsync(Exception ex)
{
    await Task.Run(() => {
        Console.WriteLine($"I am going to throw \"{ex.Message}\"");
        throw ex;
    });
}

Output

请注意，由于竞争条件，“我要抛出”消息的输出顺序可能会改变。

I am going to throw "Exception #0"
I am going to throw "Exception #1"
I am going to throw "Exception #2"
I am going to throw "Exception #3"
I am going to throw "Exception #4"
"Exception #0" was thrown

那是因为await“展开”聚合异常并始终仅抛出第一个异常（如文档中所述await https://learn.microsoft.com/en-us/dotnet/csharp/language-reference/keywords/await），即使你在等待Task.WhenAll这显然会导致多个错误。您可以像这样访问聚合异常：

var whenAll = Task.WhenAll(tasks);
try {
    await whenAll;
}
catch  {
    // this is `AggregateException`
    throw whenAll.Exception;
}

或者您可以循环执行任务并检查每个任务的状态和异常。

请注意，修复后您还需要做一件事：

try {
    ThrowSeveralExceptionsAsync(5).Wait();
}
catch (AggregateException ex) {
    // flatten, unwrapping all inner aggregate exceptions
    ex.Flatten().Handle(innerEx => {
        Console.WriteLine($"\"{innerEx.Message}\" was thrown");
        return true;
    });
}

因为任务返回的是ThrowSeveralExceptionsAsync包含AggregateException我们扔了，裹在另一个里面AggregateException.