仅当调用 ThrowIfCancellationRequested 时任务才会被取消

Fel*_*rea 1 c# task-parallel-library async-await .net-core

我有一个正在进行无限循环的任务。

我有一个 CancellationToken,我将其传递给 Task.Run 调用以获取实际的 ExecutePoll 函数。

我等待几秒钟并取消令牌。

当任务被取消时,应该运行一个延续。

事实证明,只有当我显式调用cancelToken.ThrowIfCancellationRequested()时,此延续才会运行;。如果我只跳出循环,任务始终处于状态:RanToCompletion

谁能分享一些关于我在这里出错的信息?

代码:

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

namespace TaskCancellationTest
{
    class Program
    {
        private static CancellationTokenSource _pollProcessTokenSource;

        static async Task Main(string[] args)
        {
            InitPollingProcess();

            await Task.Delay(5000);

            Console.WriteLine("Cancelling loop");
            _pollProcessTokenSource.Cancel();
            Console.WriteLine("Loop cancelled");

            Console.ReadLine();
        }

        private static void InitPollingProcess()
        {
            try
            {
                _pollProcessTokenSource = new CancellationTokenSource();

                Task pollForListenerConfigs = Task.Run(async () =>
                {
                    await ExecutePoll(_pollProcessTokenSource.Token);
                },
                    _pollProcessTokenSource.Token);

                pollForListenerConfigs.ContinueWith(_ =>
                {
                    Console.WriteLine("Poll process stopped!");
                }, TaskContinuationOptions.OnlyOnCanceled);

                pollForListenerConfigs.ContinueWith(t =>
                {
                    Console.WriteLine($"Task status: {t.Status}");
                });
            }
            catch (Exception ex)
            {
                Console.WriteLine($"Poll process failed with Exception:\n {ex.Message}");
            }
        }

        private static async Task ExecutePoll(CancellationToken cancellationToken)
        {
            while (true)
            {
                if (cancellationToken.IsCancellationRequested)
                {
                    Console.WriteLine("Exit from poll loop!");
                    //cancellationToken.ThrowIfCancellationRequested(); // UNCOMMENT TO MAKE CONTINUATION RUN
                    break;
                }

                Console.WriteLine("Looping...");

                await Task.Delay(1000);
            }
        }
    }
}
Run Code Online (Sandbox Code Playgroud)

YK1*_*YK1 5

没有什么问题,这里解释得很好:

您可以使用以下选项之一终止操作:

  • 只需从代表返回即可。在许多情况下这已经足够了;但是,以这种方式取消的任务实例会转换为 TaskStatus.RanToCompletion 状态,而不是 TaskStatus.Canceled 状态。

  • 通过抛出 OperationCanceledException 并向其传递请求取消的令牌。执行此操作的首选方法是使用 ThrowIfCancellationRequested 方法。以这种方式取消的任务将转换为“已取消”状态,调用代码可以使用该状态来验证该任务是否响应了其取消请求。