1. 程式人生 > >多線程之取消架構

多線程之取消架構

tor 同步機制 集合 loop 標準 需要 name targe sage

  .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);
                }
            }
        }

  輸出:
  技術分享

多線程之取消架構