1

Task.WhenAll调用中导致多个异常时,一旦您通过多于一层的等待等待它,看起来只有一个异常被吸收到任务中。我的印象是该Task.Exception.InnerExceptions属性将包含所有发生的异常,但在某些情况下,它们似乎只有一个。

例如,此示例代码创建多个引发异常的任务,然后在它们上等待一个 Task.WhenAll,然后写入控制台它能够捕获的异常:

class Program
{
    static async Task Main(string[] args)
    {
        var task = CauseMultipleExceptionsAsync();

        // Delaying until all the Exceptions have been thrown, ensuring it isn't just a weird race condition happening behind the scenes
        await Task.Delay(5000);

        try
        {
            await task;
        }
        catch(AggregateException e)
        {
            // This does not get hit
            Console.WriteLine($"AggregateException caught: Found {e.InnerExceptions.Count} inner exception(s)");
        }
        catch(Exception e)
        {
            Console.WriteLine($"Caught other Exception {e.Message}");

            Console.WriteLine($"task.Exception.InnerExceptions contains {task.Exception.InnerExceptions.Count} exception(s)");
            foreach (var exception in task.Exception.InnerExceptions)
            {
                Console.WriteLine($"Inner exception {exception.GetType()}, message: {exception.Message}");
            }
        }
    }

    static async Task CauseMultipleExceptionsAsync()
    {
        var tasks = new List<Task>()
        {
            CauseExceptionAsync("A"),
            CauseExceptionAsync("B"),
            CauseExceptionAsync("C"),
        };

        await Task.WhenAll(tasks);
    }

    static async Task CauseExceptionAsync(string message)
    {
        await Task.Delay(1000);
        Console.WriteLine($"Throwing exception {message}");
        throw new Exception(message);
    }
}

我期望这要么进入catch(AggregateException e)子句,要么至少有三个内部异常task.Exception.InnerExceptions- 引发一个异常的实际情况是,只有一个异常在task.Exception.InnerExceptions

Throwing exception B
Throwing exception A
Throwing exception C
Caught other Exception A
task.Exception.InnerExceptions contains 1 exception(s)
Inner exception System.Exception, message: A

更奇怪的是,这种行为会根据您是否等待Task.WhenAll调用而改变CauseMultipleExceptionsAsync——如果您直接返回任务而不是等待它,那么所有三个异常都会出现在task.Exception.InnerException. 例如,替换CauseMultipleExceptionsAsync为:

    static Task CauseMultipleExceptionsAsync()
    {
        var tasks = new List<Task>()
        {
            CauseExceptionAsync("A"),
            CauseExceptionAsync("B"),
            CauseExceptionAsync("C"),
        };

        return Task.WhenAll(tasks);
    }

给出这个结果,task.Exception.InnerExceptions 中包含所有三个异常:

Throwing exception C
Throwing exception A
Throwing exception B
Caught other Exception A
task.Exception.InnerExceptions contains 3 exception(s)
Inner exception System.Exception, message: A
Inner exception System.Exception, message: B
Inner exception System.Exception, message: C

我对此感到很困惑 - 在最初的示例中异常 B 和 C 去了哪里?如果 Task.Exception 不包含有关它们的任何信息,您将如何再次找到它们?为什么 awaiting insideCauseMultipleExceptionsAsync隐藏了这些异常,而Task.WhenAll直接返回却没有?

如果它有所作为,我可以在 .Net Framework 4.5.2 和 .Net Core 2.1 中复制上述内容。

4

1 回答 1

2

您正在观察的是await操作员的行为,而不是Task.WhenAll方法的行为。如果你对为什么会有这种await行为感兴趣,你可以阅读async/await 早期的这篇文章:

可以选择总是扔第一个或总是扔一个聚合,因为await我们选择总是扔第一个。但这并不意味着您无法访问相同的详细信息。在所有情况下,Task 的 Exception 属性仍然返回AggregateException包含所有异常的一个,因此您可以捕获任何抛出的异常并Task.Exception在需要时返回进行咨询。task.Wait()是的,这会导致在和之间切换时的异常行为之间存在差异await task,但我们认为这是两害相权取其轻。

如果您想实现一种行为类似于 的方法Task.WhenAll,但又不失异步/等待机制的便利性,这很棘手,但这里有可用的变通方法

于 2020-04-22T20:28:37.430 回答