多線程之取消架構

　　.NET 4.5 中包含取消架構，允許以標準方式取消長時間運行的任務。每個阻塞調用都應支持這種機制。但目前，並不是所有阻塞調用都實現了這個新技術。已經實現了這種機制的技術有任務(http://www.cnblogs.com/afei-24/p/6907840.html)，併發集合類(http://www.cnblogs.com/afei-24/p/6836976.html)，並行LINQ(http://www.cnblogs.com/afei-24/p/6860753.html)和幾種同步機制。
　　取消架構基於協作行為，它不是強制的。長時間運行的任務會檢查它是否被取消，並返回控制權。
　　支持取消的方法接受一個CancellationToken參數。這個類定義了IsCancellationRequested屬性，其中長時間運行的操作可以檢查它是否應終止。使用Register()方法註冊一個將在取消此 System.Threading.CancellationToken 時調用的委托。它在調用Cancel()方法取消操作時調用。

1.Parallel.For()方法的取消
　　Parallel類提供了For()方法的重載版本，在重載版本中，可以傳遞ParallelOptions類型的參數。使用ParallelOptions類型，可以傳遞一個CancellationToken參數。CancellationToken參數通過創建CancellationTokenSource來生成。由於CancellationTokenSource實現了ICancelableOperation介面，因此可以用CancellationToken註冊，並允許使用Cancle()，CancleAfter()等方法取消操作。
　　示例：

　　　　static void CancelParallelFor()
        {
            var cts = new CancellationTokenSource();
            cts.Token.Register( ()=> Console.WriteLine("token canceled!"));

            cts.CancelAfter(1000);

            try
            {
                ParallelLoopResult plr =
                    Parallel.For(0, 100, new ParallelOptions { CancellationToken = cts.Token },
                    x => {
                        Console.WriteLine("loop {0} started", x);
                        Thread.Sleep(1000);
                        Console.WriteLine("loop {0} fininshed!", x);
                    });
            }
            catch (OperationCanceledException ex)
            {
                Console.WriteLine(ex.Message);

            }
        }

　　輸出：
　　

　　在For迴圈的實現代碼中，Parallel類驗證CancellationToken的結果，並取消操作。一旦取消操作，For()方法就拋出一個OperationCanceledException類型的異常。
　　由輸出可看出，當取消操作時，已啟動的操作允許完成，因為取消操作總是以協作方式進行，以避免在取消迭代操作的中間泄露資源。

2.任務的取消
　　任務的取消類似Parallel.For()方法的取消。首先，創建一個CancellationTokenSource。如果只需要一個取消標記，可以訪問Task.Factory.CancellationToken,以使用預設的取消標記。任務通過TaskFactory對象接受取消標記。在構造函數中，把取消標記賦予TaskFactory。這個取消標記又任務用於檢查CancellationToken的IsCancellationRequested屬性，以確定是否請求了取消。
　　示例：

　　　　static void CancelTask()
        {
            var cts = new CancellationTokenSource();

            cts.Token.Register(() => Console.WriteLine("task cancelled!"));

            cts.CancelAfter(2000);
            


            try
            {
                Task t = Task.Run(() =>
                {
                    CancellationToken token = cts.Token;
                    Console.WriteLine("task stared!");
                    for (int i = 0; i < 20; i++)
                    {
                        Thread.Sleep(500);
                        if (cts.IsCancellationRequested)
                        {
                            Console.WriteLine("cancelled!");
                            token.ThrowIfCancellationRequested();//拋出異常
                            break;
                        }
                        Console.WriteLine("in loop!");
                    }
                }, cts.Token);
                t.Wait();
            }
            catch (AggregateException ex)
            {
                Console.WriteLine("exception:{0},{1}",ex.GetType().Name,ex.Message);
                foreach (var innerEx in ex.InnerExceptions)
                {
                    Console.WriteLine("exception:{0},{1}", ex.InnerException.GetType().Name, ex.InnerException.Message);
                }
            }
        }

　　輸出：