为什么Task.WhenAny没有抛出预期的TimeoutException？

Question

请遵守以下简单的代码:

class Program
{
    static void Main()
    {
        var sw = new Stopwatch();
        sw.Start();
        try
        {
            Task.WhenAny(RunAsync()).GetAwaiter().GetResult();
        }
        catch (TimeoutException)
        {
            Console.WriteLine("Timed out");
        }
        Console.WriteLine("Elapsed: " + sw.Elapsed);
        Console.WriteLine("Press Enter to exit");
        Console.ReadLine();
    }

    private static async Task RunAsync()
    {
        await Observable.StartAsync(async ct =>
        {
            for (int i = 0; i < 10; ++i)
            {
                await Task.Delay(500, ct);
                Console.WriteLine("Inside " + i);
            }
            return Unit.Default;
        }).Timeout(TimeSpan.FromMilliseconds(1000));
    }
}

运行它输出:

Inside 0
Inside 1
Elapsed: 00:00:01.1723818
Press Enter to exit

注意,没有超时消息.

现在,如果我更换Task.WhenAny与Task.WhenAll这里是我得到:

Inside 0
Inside 1
Timed out
Elapsed: 00:00:01.1362188
Press Enter to exit

请注意这次出现Timed out消息.

并且,如果我删除Task.WhenAll包装器并RunAsync直接调用:

Inside 0
Inside 1
Timed out
Elapsed: 00:00:01.1267617
Press Enter to exit

该超时消息是存在的,符合市场预期.

那么交易是Task.WhenAny什么？它显然会中断异步方法,但是在哪里TimeoutException？

Answer 1

Task.WhenAny不会从单个任务中重新抛出异常(与此不同Task.WhenAll):

"当任何提供的任务完成时,返回的任务将完成.返回的任务将始终RanToCompletion以Result设置为第一个任务的状态结束.即使第一个完成的任务以Canceled或Faulted状态结束,也是如此. "

从 Task.WhenAny

这意味着无论没有任何类型的例外,它都将成功完成.

要实际重新抛出单个已完成任务的例外,您需要await返回的任务本身:

var completedTask = await Task.WhenAny(tasks); // no exception
await completedTask; // possible exception

或者在你的情况下:

Task.WhenAny(RunAsync()).GetAwaiter().GetResult().GetAwaiter().GetResult();