为什么抛出 Task.WhenAll 时没有捕获异常？

Question

我遇到的问题是异常（标记如下）在抛出到围绕Task.WhenAll 的catch 语句时没有被捕获。我不确定为什么这个异常会膨胀到调用堆栈。

我阅读了以下article，其中声明了一个包装等待的任务的 try/catch。WhenAll 将捕获抛出的第一个异常，但对我来说似乎并非如此......

我在下面有以下代码 sn-p（您可以复制并粘贴它并点击“运行”）以重现（.netcoreapp2.1）。

using System;
using System.Threading.Tasks;
using System.Threading;


namespace TestProgram
{
    class Program
    {
        public static void Main(string[] args)
        {
            MainAsync(args).GetAwaiter().GetResult();
        }

        private static async Task MainAsync(string[] args)
        {
            CancellationTokenSource tokenSource = new CancellationTokenSource();
            var token = tokenSource.Token;
            var thread = new Thread(() => CancelToken(tokenSource));
            thread.IsBackground = true;
            thread.Start();
            var ourTask = SpinUntilCancelled(token);
            try
            {
                await Task.WhenAll(ourTask);
            }
            catch (Exception ex) // NOT CATCHING AND PRINTING!
            { Console.WriteLine($"{ex}"); }
        }

        private static void CancelToken(CancellationTokenSource obj)
        {
            Thread.Sleep(5000);
            obj.Cancel();
            obj.Dispose();
            return;
        }

        private static Task SpinUntilCancelled(CancellationToken cancellation)
        {
            int i = 0;
            while (true)
            {
                try
                {
                    if (cancellation.IsCancellationRequested)
                        throw new ApplicationException("Token cancelled");
                    Thread.Sleep(1000);
                    Console.WriteLine($"Text {++i}");
                }
                catch
                {
                    Console.WriteLine("Cancelled!");
                    cancellation.ThrowIfCancellationRequested();

                }
            }
        }
    }
}

如你所见，我的断点没有被命中。

Answer 1

由于while (true) 和缺少break 或return 语句，SpinUntilCancelled 方法永远不会产生值，因此它的返回类型无关紧要。为了让它产生一个实际的Task，你以后可以await，你应该给它一个适当的异步实现，像这样：

private static async Task SpinUntilCancelled(CancellationToken cancellationToken)
{
    int i = 0;
    while (true)
    {
        cancellationToken.ThrowIfCancellationRequested();
        await Task.Delay(1000, cancellationToken);
        Console.WriteLine($"Text {++i}");
    }
}

附带说明，如果您想在取消CancellationTokenSource 时获得即时通知，您可以像这样通过Register 回调其Token：

var tokenSource = new CancellationTokenSource();
tokenSource.Token.Register(() => Console.WriteLine("Token canceled"));