2019-1-24-Task真的取消了么

黄腾霄

发布于 2020-06-10 11:28:43

5770

发布于 2020-06-10 11:28:43

文章被收录于专栏：黄腾霄的博客

我们都知道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秒后就进行取消。

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

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

        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("取消任务");
        }

结果是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("取消任务");
        }

任务有被正常取消了

原因

实际上，当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("取消任务");
        }

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

        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("取消任务");
        }