欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

c# Task任務(wù)的取消方式

 更新時間:2024年12月31日 08:57:11   作者:皮皮君  
文章介紹了如何在C#中使用CancellationTokenSource和CancellationToken來取消任務(wù),通過Task.Run方法和CancellationToken參數(shù),可以控制任務(wù)的執(zhí)行,并在需要時取消它們,文章還討論了CancellationToken參數(shù)的重要性

Task任務(wù)的取消

c# 任務(wù)的取消,需要用到CancellationTokenSource類,CancellationToken結(jié)構(gòu)體。

注意:CancellationTokenSource是class類型,而CancellationToken是struct結(jié)構(gòu)體。

任務(wù)內(nèi)部"監(jiān)聽"CancellationToken方法

任務(wù)的內(nèi)部在合適的時候不停地調(diào)用CancellationToken的ThrowIfCancellationRequested()方法,這個函數(shù)會拋出一個叫做OperationCanceledException的異常,它的實現(xiàn)(微軟開源代碼)如下:

        public void ThrowIfCancellationRequested()
        {
            if (IsCancellationRequested) 
                ThrowOperationCanceledException();
        }

下面的列子通過Task.Run產(chǎn)生了一個任務(wù)。Task任務(wù)的內(nèi)部正式通過拋出OperationCanceledException異常達到被取消的目的。而任務(wù)的外部則是通過調(diào)用CancellationTokenSource實例的Cancel()方法來觸發(fā)取消的動作的。

下面的例子是一個取消Task任務(wù)的例子

using System;
using System.Threading;
using System.Threading.Tasks;

class Program
{
    static async Task Main()
    {
        var tokenSource2 = new CancellationTokenSource();
        CancellationToken ct = tokenSource2.Token;
        var tokenSource3 = new CancellationTokenSource();

        var task = Task.Run(() =>
        {
            // Were we already canceled?
            ct.ThrowIfCancellationRequested();
            
            bool moreToDo = true;
            while (moreToDo)
            {
                // Poll on this property if you have to do
                // other cleanup before throwing.
                // Clean up here, then...
                if(ct.IsCancellationRequested)
                {
                    ct.ThrowIfCancellationRequested();
                }
            }
        },tokenSource2.Token); // Pass same token to Task.Run.

        Thread.Sleep(5000);
        tokenSource2.Cancel();

        // Just continue on this thread, or await with try-catch:
        try
        {
            await task;
        }
        catch (OperationCanceledException e)
        {
            Console.WriteLine($"{nameof(OperationCanceledException)} thrown with message: {e.Message}");
            bool eqs = e.CancellationToken.Equals(tokenSource3.Token);
            System.Console.WriteLine($"Equals' result: {eqs}.");
            System.Console.WriteLine($"Task's status: {task.Status}");
        }
        catch (Exception ex)
        {
            System.Console.WriteLine(ex.Message);
        }
        finally
        {
            tokenSource2.Dispose();
        }

        Console.ReadKey();
    }
}
/*
The operation was canceled.
OperationCanceledException thrown with message: The operation was canceled.
Equals' result: False.
Task's status: Canceled
*/

這個例子中我們在Task的外部創(chuàng)建了2個CancellationTokenSource實例,因為CancellationTokenSource類包含一個CancellationToken類的屬性Token,這也就意味著例子當中包含了兩個CancellationToken實例。

ThrowIfCancellationRequested()方法會把調(diào)用它的CancellationToken實例也作為參數(shù)一起攜帶拋出。

因此catch塊參數(shù)e中包含的是tokenSource2.Token,因此它與tokenSource3.Token進行相等比較輸出一定是false。

又因為Task.Run()方法中傳入的第二個參數(shù)也是tokenSource2.Token,Task核心框架內(nèi)部會比較OperationCanceledException異常中攜帶的CancellationToken實例和Task.Run()方法中傳入的CancellationToken實例,如果兩者是一樣的,則Task的status狀態(tài)設(shè)為Canceled,表示成功取消;如果兩者不一樣,Task任務(wù)仍然會退出,但是Task的status狀態(tài)設(shè)為Faulted,表示出錯。

如果將第29行改為:

},tokenSource3.Token); // Pass same token to Task.Run.

則,結(jié)果輸出如下:

OperationCanceledException thrown with message: The operation was canceled.
Equals' result: False.
Task's status: Faulted

看起來,Task任務(wù)也被取消了,但是實際上是由于出錯而退出。因此,Task.Run的第二個參數(shù)可以用來確保內(nèi)部實際引發(fā)取消異常的CancellationToken實例和Task.Run傳入的CancellationToken實例要一致才能成功取消,否則框架會誤認為你是誤操作而導(dǎo)致退出的。因此,Task.Run的CancellationToken參數(shù)是為了更加安全。

如果將29行改為不帶CancellationToken參數(shù)的重載函數(shù),那么返回的也是一樣的Faulted結(jié)果。

總結(jié)

以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。

相關(guān)文章

最新評論