2019-1-27-Task真的取消了么（2）

黄腾霄

发布于 2020-06-10 11:29:31

4320

发布于 2020-06-10 11:29:31

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

在之前的博客2019-1-24-Task真的取消了么 - huangtengxiao介绍了task.run需要在方法执行过程中主动调用ThrowIfCancellationRequested()才能取消，这次我们研究下其他情况的取消场景

Task .Delay

我们知道Task.Dealy也有一个重载可以传入CancellationToken,我们做如下实验

        static void Main(string[] args)
        {
            var source = new CancellationTokenSource();
            Foo(source.Token);
            Thread.Sleep(TimeSpan.FromSeconds());
            source.Cancel();
            Console.WriteLine("取消任务");
            Console.ReadLine();
        }

        public static void Foo(CancellationToken token)
        {
            Task.Delay(TimeSpan.FromSeconds(), token)
                .ContinueWith(task => Console.WriteLine(task.Status));
        }

和之前实验类似，只是Task.Run换成了Task.Delay。结果如图所示

可见Task.Delay可以直接响应取消

Parallel

我们再对Parallel做实验

        static void Main(string[] args)
        {
            var source = new CancellationTokenSource();
            Foo(source.Token);
            Thread.Sleep(TimeSpan.FromSeconds(3));
            source.Cancel();
            Console.WriteLine("取消任务");
            Console.ReadLine();
        }

        public static void Foo(CancellationToken token)
        {
            var options = new ParallelOptions()
            {
                CancellationToken = token,
            };
            Task.Run(() =>
            {
                Parallel.For(0, 10, options, (i, state) =>
                {
                    Console.WriteLine($"{i}任务开始");
                    Thread.Sleep(TimeSpan.FromSeconds(5));
                    Console.WriteLine($"{i}任务结束");
                });
            });
        }

通过Parallel.For创建10个并行任务，每个任务需要5秒钟，而第3秒时取消任务。结果如图所示