意外的任务取消行为

Pav*_*ins 5 .net c# task async-await

我创建了一个简单的.NET Framework 4.7.2 WPF应用程序,其中包含两个控件-文本框和按钮。这是我的代码背后:

private async void StartTest_Click(object sender, RoutedEventArgs e)
{
    Output.Clear();

    var cancellationTokenSource = new CancellationTokenSource();

    // Fire and forget
    Task.Run(async () => {
        try
        {
            await Task.Delay(TimeSpan.FromMinutes(1), cancellationTokenSource.Token);
        }
        catch (OperationCanceledException)
        {
            Task.Delay(TimeSpan.FromSeconds(3)).Wait();
            Print("Task delay has been cancelled.");
        }
    });

    await Task.Delay(TimeSpan.FromSeconds(1));
    await Task.Run(() =>
    {
        Print("Before cancellation.");
        cancellationTokenSource.Cancel();
        Print("After cancellation.");
    });
}

private void Print(string message)
{
    var threadId = Thread.CurrentThread.ManagedThreadId;
    var time = DateTime.Now.ToString("HH:mm:ss.ffff");
    Dispatcher.Invoke(() =>
    {
        Output.AppendText($"{ time } [{ threadId }] { message }\n");
    });
}
Run Code Online (Sandbox Code Playgroud)

按下StartTest按钮后,我在Output文本框中看到以下结果:

12:05:54.1508 [7] Before cancellation.
12:05:57.2431 [7] Task delay has been cancelled.
12:05:57.2440 [7] After cancellation.
Run Code Online (Sandbox Code Playgroud)

我的问题是,为什么[7] Task delay has been cancelled.在请求取消令牌的同一线程中执行?

我希望看到的[7] Before cancellation.,然后[7] After cancellation.,然后Task delay has been cancelled.。或至少Task delay has been cancelled.在另一个线程中执行。

请注意,如果我cancellationTokenSource.Cancel()从主线程执行,则输出看起来像预期的那样:

12:06:59.5583 [1] Before cancellation.
12:06:59.5603 [1] After cancellation.
12:07:02.5998 [5] Task delay has been cancelled.
Run Code Online (Sandbox Code Playgroud)

更新

有趣的是当我更换

12:05:54.1508 [7] Before cancellation.
12:05:57.2431 [7] Task delay has been cancelled.
12:05:57.2440 [7] After cancellation.
Run Code Online (Sandbox Code Playgroud)

12:06:59.5583 [1] Before cancellation.
12:06:59.5603 [1] After cancellation.
12:07:02.5998 [5] Task delay has been cancelled.
Run Code Online (Sandbox Code Playgroud)

.NET使该后台线程保持繁忙状态,并且输出再次如预期的那样:

12:08:15.7259 [5] Before cancellation.
12:08:15.7289 [5] After cancellation.
12:08:18.8418 [7] Task delay has been cancelled..
Run Code Online (Sandbox Code Playgroud)

更新2

我已对代码示例进行了稍许更新,以期使内容更加清晰。

请注意,这不是纯粹的假设问题,而是我花了很多时间在生产代码中理解的一个实际问题。但是为了简洁起见,我创建了这个极其简化的代码示例,以说明相同的行为。

Ste*_*ary 5

我的问题是,为什么[7] Task delay has been cancelled.在请求取消令牌的同一线程中执行?

这是因为await使用ExecuteSynchronouslyflag 调度其任务继续。我也认为这种行为是令人惊讶的,并最初将其报告为错误(按“按设计要求封闭”)。

更具体地说,await捕获一个上下文,并且如果该上下文与正在完成任务的当前上下文兼容,那么async继续将直接在正在完成该任务的线程上执行。

要逐步执行:

  • 一些线程池线程“ 7”运行cancellationTokenSource.Cancel()
  • 这会使CancellationTokenSource进入取消状态并运行其回调。
  • 这些回调之一在内部Task.Delay。该回调不是特定于线程的,因此它在线程7上执行。
  • 这将导致Task返回的Task.Delay被取消。在await已安排的从一个线程池线程延续,线程池中的线程都被认为是互相兼容的,因此,async继续直接执行上线7。

提醒一下,线程池线程仅在有要运行的代码时使用。使用awaitto 发送异步代码时Task.Run,它可以await在一个线程上运行第一部分(直到),然后在另一个线程上运行另一部分(在之后await)。

因此,由于线程池线程是可互换的,因此线程7 asyncawait; 之后继续执行该方法不是“错误的” 。这只是一个问题,因为现在继续执行之后的代码Cancel被阻止了async

请注意,如果我从主线程执行cancelTokenSource.Cancel(),则输出将按预期进行

这是因为UI上下文被认为与线程池上下文兼容。因此,取消Task返回时Task.Delayawait将看到它在UI上下文中,而不是在线程池上下文中,因此它将其延续性排队到线程池中,而不是直接执行。

有趣的是,当我替换Task.Delay(TimeSpan.FromMinutes(1), cancellationTokenSource.Token)cancellationTokenSource.Token.ThrowIfCancellationRequested().NET时,该后台线程保持忙碌状态,并且输出再次达到预期

这不是因为线程“忙”。这是因为没有回调了。因此,观察方法是轮询而不是被通知

该代码设置了一个计时器(通过Task.Delay),然后将线程返回到线程池。当计时器关闭时,它将从线程池中获取一个线程,并检查取消令牌源是否已取消;如果不是,它将设置另一个计时器并将线程再次返回到线程池。本段的要点是,Task.Run它不仅仅代表“一个线程”;它在执行代码时仅具有一个线程(即,在中没有await),并且该线程可以在any之后更改await


的一般问题,await使用ExecuteSynchronously通常不,除非你是混合阻塞和异步代码的问题。在这种情况下,最好的解决方案是将阻塞代码更改为异步代码。如果您无法做到这一点,则需要注意如何继续在async之后阻塞的方法await。这主要是TaskCompletionSource<T>和的问题CancellationTokenSourceTaskCompletionSource<T>有一个很好的RunContinuationsAsynchronously选项可以覆盖该ExecuteSynchronously标志;不幸的是,CancellationTokenSource没有;您必须Cancel使用来将对线程池的调用排队Task.Run

奖金:对您的队友测验