2

我真的不明白这一点。在我下面的代码中，按原样运行，token.ThrowIfCancellationRequested() 抛出的异常不会被发送回 Main 使用 .Wait() 的位置，而是当场抛出，堆栈跟踪并不知道它发生在哪里除了“任务已取消”。但是，如果我删除 async 关键字并使用 await Task.Delay() 删除 try catch 块，它确实会被发送回 main 中的 .Wait() 并被捕获。

我是不是做错了什么，或者我究竟如何让 await Task.Delay() 和 token.ThrowIfCancellationRequested() 抛出的异常都冒泡到 .Wait()？

static void Main(string[] args)
{
    var t = new CancellationTokenSource();
    var task = Task.Factory.StartNew((x) => Monitor(t.Token), t.Token, TaskCreationOptions.LongRunning);

    while (true)
    {
        if (Console.ReadLine() == "cancel")
        {
            t.Cancel();
            try 
            {
                task.Wait();
            }
            catch(AggregateException)
            {
                Console.WriteLine("Exception via task.Wait()");

            }
            Console.WriteLine("Cancelled");
        }
    }
}

static async void Monitor(CancellationToken token)
{
    while(true)
    {
        for(int i = 0; i < 5; i++)
        {
            // If the async in the method signature, this does not send the exception to .Wait();
            token.ThrowIfCancellationRequested();

            // Do Work
            Thread.Sleep(2000);
        }

        // Wait 10 seconds before doing work again.

        // When this try block is removed, and the async is taken out of the method signature,
        // token.ThrowIfCancellationRequested() properly sends the exception to .Wait()
        try
        {
            await Task.Delay(10000, token);
        } 
        catch(TaskCanceledException) 
        {
            Console.WriteLine("Exception from Delay()");
            return;
        }
    }
}
4

1 回答 1

2

你应该避免async void。它的异常处理语义很棘手，无法组合成其他async方法。

async void方法在概念上是事件处理程序，因此如果它引发异常，它将直接在其上SynchronizationContext引发 - 在这种情况下，在线程池线程上引发。

-returning 方法的异步等价物void不是async void-returning 方法；这是一个async Task返回方法。所以你的Monitor方法应该返回Task：

static void Main(string[] args)
{
  var t = new CancellationTokenSource();
  var task = Monitor(t.Token);

  while (true)
  {
    if (Console.ReadLine() == "cancel")
    {
      t.Cancel();
      try 
      {
        task.Wait();
      }
      catch(AggregateException)
      {
        Console.WriteLine("Exception via task.Wait()");
      }
      Console.WriteLine("Cancelled");
    }
  }
}

static async Task Monitor(CancellationToken token)

不用担心错过LongRunningflag；这只是一种优化，没有它线程池也能正常工作。

您可能会发现我的async/ awaitintro或官方 MSDN 文档很有帮助。

于 2012-12-04T13:23:23.887 回答