快捷導(dǎo)航

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

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

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

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

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

Parallel類提供了For()方法的重載版本，在重載版本中，可以傳遞ParallelOptions類型的參數(shù)。使用ParallelOptions類型，可以傳遞一個(gè)CancellationToken參數(shù)。CancellationToken參數(shù)通過(guò)創(chuàng)建CancellationTokenSource來(lái)生成。由于CancellationTokenSource實(shí)現(xiàn)了ICancelableOperation接口，因此可以用CancellationToken注冊(cè)，并允許使用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)的實(shí)現(xiàn)代碼中，Parallel類驗(yàn)證CancellationToken的結(jié)果，并取消操作。一旦取消操作，F(xiàn)or()方法就拋出一個(gè)OperationCanceledException類型的異常。
由輸出可看出，當(dāng)取消操作時(shí)，已啟動(dòng)的操作允許完成，因?yàn)槿∠僮骺偸且詤f(xié)作方式進(jìn)行，以避免在取消迭代操作的中間泄露資源。

2.任務(wù)的取消

任務(wù)的取消類似Parallel.For()方法的取消。首先，創(chuàng)建一個(gè)CancellationTokenSource。如果只需要一個(gè)取消標(biāo)記，可以訪問(wèn)Task.Factory.CancellationToken,以使用默認(rèn)的取消標(biāo)記。任務(wù)通過(guò)TaskFactory對(duì)象接受取消標(biāo)記。在構(gòu)造函數(shù)中，把取消標(biāo)記賦予TaskFactory。這個(gè)取消標(biāo)記又任務(wù)用于檢查CancellationToken的IsCancellationRequested屬性，以確定是否請(qǐng)求了取消。
示例：

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

輸出：