Task真的取消了么

我们都知道Task.Run方法可以传入一个CancellationToken,用于取消。可是有多少人真的去了解过当调用CancellationSource.Cancel方法时,Task是否真的被取消了


我们做个实验

        public static async void Foo()
        {
            var source = new CancellationTokenSource();

            Task.Run(() =>
            {
                Thread.Sleep(TimeSpan.FromSeconds(5));
                Console.WriteLine("task 运行结束");
            }, source.Token);
            await Task.Delay(TimeSpan.FromSeconds(3));
            source.Cancel();
            Console.WriteLine("取消任务");
        }

创建上述程序,让一个Task运行5秒后输出”task运行结束”,而在3秒后就进行取消。

1548577331312

令人惊讶的是任务竟然顺利执行完成。

为了进一步确认结果,我们添加一个后续任务,查看下之前任务的结束状态

        public static async void Foo()
        {
            var source = new CancellationTokenSource();

            Task.Run(() =>
            {
                Thread.Sleep(TimeSpan.FromSeconds(5));
                Console.WriteLine("task 运行结束");
            }, source.Token).ContinueWith(task => Console.WriteLine(task.Status));
            await Task.Delay(TimeSpan.FromSeconds(3));
            source.Cancel();
            Console.WriteLine("取消任务");
        }
1548577616715

结果是RanToCompletion而不是Canceled,这说明任务根本没有被取消

我们如果不在取消前等待3秒,并且添加任务运行开始日志

        public static async void Foo()
        {
            var source = new CancellationTokenSource();

            Task.Run(() =>
            {
                Console.WriteLine("task 运行开始");
                Thread.Sleep(TimeSpan.FromSeconds(5));
                Console.WriteLine("task 运行结束");
            }, source.Token).ContinueWith(task => Console.WriteLine(task.Status));
            source.Cancel();
            Console.WriteLine("取消任务");
        }
1548577856869

任务有被正常取消了

原因

实际上,当Task.Run的任务真正开始执行后,调用CancellationSource.Cancel方法并不能取消任务,或者结束调用线程。调用的方法仍然会顺利执行。

那么带有CancellationToken的方法重载有什么用呢?

1、如第三个例子所示,在任务运行开始之前,调用Cancel可以直接取消任务,避免额外消耗一个线程

2、当对应的token,在执行体中抛出OperationCanceledException,(即调用CancellationToken.ThrowIfCancellationRequested())可以将其捕获,并且将任务状态置为Canceled

        public static async void Foo()
        {
            var source = new CancellationTokenSource();

            Task.Run(() =>
            {
                Console.WriteLine("task 运行开始");
                Thread.Sleep(TimeSpan.FromSeconds(5));
                source.Token.ThrowIfCancellationRequested();
                Console.WriteLine("task 运行结束");
            },source.Token).ContinueWith(task => Console.WriteLine(task.Status));
            await Task.Delay(TimeSpan.FromSeconds(3));
            source.Cancel();
            Console.WriteLine("取消任务");
        }
1548578521834

而如果没有使用这个重载,任务会因未捕获异常而终止,并非取消

        public static async void Foo()
        {
            var source = new CancellationTokenSource();

            Task.Run(() =>
            {
                Console.WriteLine("task 运行开始");
                Thread.Sleep(TimeSpan.FromSeconds(5));
                source.Token.ThrowIfCancellationRequested();
                Console.WriteLine("task 运行结束");
            }).ContinueWith(task => Console.WriteLine(task.Status));
            await Task.Delay(TimeSpan.FromSeconds(3));
            source.Cancel();
            Console.WriteLine("取消任务");
        }
1548578490122

所以我们为Task.Run添加了CancellationToken后仍需要,在方法执行时手动判断token是否取消

参考链接:

原文出处:黄腾霄

原文链接:https://huangtengxiao.gitee.io/post/Task%E7%9C%9F%E7%9A%84%E5%8F%96%E6%B6%88%E4%BA%86%E4%B9%88.html

本文观点不代表Dotnet9立场,转载请联系原作者。

发表评论

登录后才能评论