.Net 异步随手记（三）

从《.Net 异步随手记（二）》来看，总感觉还差点儿什么，就是对不同情况的处理。比如当一个 Task 完成了后，我想让它继续执行 T1，如果被取消了就去执行 T2，如果...就去执行 T3，那怎么写呢？

过程是痛苦的，我笨了两天，终于搞通了。之前一直疑惑，为什么引发了 CancellationTokenSource 的 Cancel 方法，捕捉到的 Task 的 IsCanceled 属性依然是 False，今天晚上终于捕捉到了，看来还是自己写的有问题，不废话了，把代码记录一下：

namespace TaskConsole
{
    class Program
    {
        static void Main(string[] args)
        {
            while (true)
            {
                var enter = Console.ReadLine();

                if (enter.ToLower() == "continue")
                {
                    cancelSource = new CancellationTokenSource();
                    token = cancelSource.Token;
                    var task = Entry();
                    Console.WriteLine(task.Status);
                }
                else if(enter.ToLower() == "cel") {
                    cancelSource.Cancel();
                }
                else { break; }
            }
        }


        async static Task DoWork(string workerName)
        {
            int count = 0;

            while (count<10)
            {
                if (token.IsCancellationRequested)
                {
                    Console.WriteLine("用户主动取消了任务");
                    token.ThrowIfCancellationRequested();
                }

                count++;
                Console.WriteLine("{0} count {1} @ Thread Id {2}", workerName, count, System.Threading.Thread.CurrentThread.ManagedThreadId);
                await Task.Delay(2000);
            }            
        }

        async static Task DoCancel(Task callbacker)
        {
            //await Task.Delay(2000);
            Console.WriteLine("Do Cancel 任务运行了");
        }

        async static Task DoContinue(Task callbacker)
        {
            //await Task.Delay(1000);
            //Console.WriteLine("Continue 任务运行了 @ Task is {1}", callbacker.Status);
            Console.WriteLine("Do Continue 运行了");
        }

        async static Task Entry()
        {
            {
                var taskWorker = Task.Factory.StartNew(() => DoWork("工作者1"));
                try
                {
                    await taskWorker.Result;
                    Console.WriteLine("taskworker 已经完成，是被取消的？ {0}", taskWorker.Result.IsCanceled);
                }
                catch (OperationCanceledException)
                {
                    Console.WriteLine("OperationCanceledException 异常，任务是被取消的？ {0}", taskWorker.Result.IsCanceled);
                }
                
                var c1 = taskWorker.Result.ContinueWith(backer => DoCancel(backer), TaskContinuationOptions.OnlyOnCanceled);
                var c2 = taskWorker.Result.ContinueWith(backer => DoContinue(backer), TaskContinuationOptions.OnlyOnRanToCompletion);
            }
        }

        static CancellationTokenSource cancelSource;
        static CancellationToken token;
    }
}

从代码可以看出，C1 = 的是 taskWorker 的 Result 的 ContinueWith，也就是说，Token 真正引发的取消操作是作用于 DoWork 方法内的，而 taskWorker 并不是 DoWork 这个异步方法的引用，而是被 Factory“创建出来的某个运行 DoWork 的 Task”。因此，想要 C1、C2起作用，必须侦测的是 DoWork 方法到底是完成了还是被取消了，而 DoWork 方法是 taskWorker 的 Result，因此代码写成这样，运行结果就正确了。

输入 continue 启动程序，如果正常执行结束，将会是这样

中途输入 cel 来手动取消，将会是这样

感谢自己这脑袋终于想明白了，总结，如果写的是

var c1 = taskWorker.ContinueWith(backer => DoCancel(backer), TaskContinuationOptions.OnlyOnCanceled);
var c2 = taskWorkert.ContinueWith(backer => DoContinue(backer), TaskContinuationOptions.OnlyOnRanToCompletion);

那 C1 就永远不会有机会运行了，因为无论 DoWork 是正常结束还是被取消了，被工厂创建出来的那个 Task （也就是 taskWorker 所指向的对象）在 DoWork 返回之后都是 RanToCompletion。