快捷導(dǎo)航

C#多線程之取消架構(gòu)介紹

更新時間：2022年04月13日 10:16:03 作者：Ruby_Lu

這篇文章介紹了C#多線程之取消架構(gòu)，文中通過示例代碼介紹的非常詳細。對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下

.NET 4.5 中包含取消架構(gòu)，允許以標準方式取消長時間運行的任務(wù)。每個阻塞調(diào)用都應(yīng)支持這種機制。但目前，并不是所有阻塞調(diào)用都實現(xiàn)了這個新技術(shù)。已經(jīng)實現(xiàn)了這種機制的技術(shù)有任務(wù)(http://www.dbjr.com.cn/article/244285.htm)，并發(fā)集合類(http://www.dbjr.com.cn/article/244141.htm)，并行LINQ(http://www.dbjr.com.cn/article/244216.htm)和幾種同步機制。
取消架構(gòu)基于協(xié)作行為，它不是強制的。長時間運行的任務(wù)會檢查它是否被取消，并返回控制權(quán)。
支持取消的方法接受一個CancellationToken參數(shù)。這個類定義了IsCancellationRequested屬性，其中長時間運行的操作可以檢查它是否應(yīng)終止。使用Register()方法注冊一個將在取消此 System.Threading.CancellationToken 時調(diào)用的委托。它在調(diào)用Cancel()方法取消操作時調(diào)用。

1.Parallel.For()方法的取消

Parallel類提供了For()方法的重載版本，在重載版本中，可以傳遞ParallelOptions類型的參數(shù)。使用ParallelOptions類型，可以傳遞一個CancellationToken參數(shù)。CancellationToken參數(shù)通過創(chuàng)建CancellationTokenSource來生成。由于CancellationTokenSource實現(xiàn)了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循環(huán)的實現(xiàn)代碼中，Parallel類驗證CancellationToken的結(jié)果，并取消操作。一旦取消操作，F(xiàn)or()方法就拋出一個OperationCanceledException類型的異常。
由輸出可看出，當取消操作時，已啟動的操作允許完成，因為取消操作總是以協(xié)作方式進行，以避免在取消迭代操作的中間泄露資源。

2.任務(wù)的取消

任務(wù)的取消類似Parallel.For()方法的取消。首先，創(chuàng)建一個CancellationTokenSource。如果只需要一個取消標記，可以訪問Task.Factory.CancellationToken,以使用默認的取消標記。任務(wù)通過TaskFactory對象接受取消標記。在構(gòu)造函數(shù)中，把取消標記賦予TaskFactory。這個取消標記又任務(wù)用于檢查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);
                }
            }
        }

輸出：