C# CancellationToken和CancellationTokenSource的用法詳解
CancellationToken
CancellationToken有一個構造函數，可以傳入一個bool類型表示當前的CancellationToken是否是取消狀態(tài)。另外，因為CancellationToken是一個結構體，所以它還有一個空參數的構造函數?！?/p>
public CancellationToken();//因為是結構體，才有空構造函數，不過沒什么作用
public CancellationToken(bool canceled);
屬性如下：
//靜態(tài)屬性，獲取一個空的CancellationToken，這個CancellationToken注冊的回調方法不會被觸發(fā)，作用類似于使用空構造函數得到的CancellationToken
public static CancellationToken None { get; }
//表示當前CancellationToken是否可以被取消
public bool CanBeCanceled { get; }
//表示當前CancellationToken是否已經是取消狀態(tài)
public bool IsCancellationRequested { get; }
//和CancellationToken關聯的WaitHandle對象，CancellationToken注冊的回調方法執(zhí)行時通過這個WaitHandle實現的
public WaitHandle WaitHandle { get; }
常用方法：
//往CancellationToken中注冊回調
public CancellationTokenRegistration Register(Action callback);
public CancellationTokenRegistration Register(Action callback, bool useSynchronizationContext);
public CancellationTokenRegistration Register([NullableAttribute(new[] { 1, 2 })] Action<object?> callback, object? state);
public CancellationTokenRegistration Register([NullableAttribute(new[] { 1, 2 })] Action<object?> callback, object? state, bool useSynchronizationContext);
//當CancellationToken處于取消狀態(tài)是，拋出System.OperationCanceledException異常
public void ThrowIfCancellationRequested();
常用的注冊回調的方法是上面4個Register方法，其中callback是回調執(zhí)行的委托，useSynchronizationContext表示是否使用同步上下文，state是往回調委托中傳的參數值
另外，Register方法會返回一個CancellationTokenRegistration結構體，當注冊回調之后，可以調用CancellationTokenRegistration的Unregister方法來取消注冊，這個Unregister方法會返回一個bool值，當成功取消時返回true，當取消失?。ū热缁卣{已執(zhí)行）將返回false:
CancellationTokenSource cancellationTokenSource = new CancellationTokenSource();
var cancellationTokenRegistration = cancellationTokenSource.Token.Register(() =>
{
Console.WriteLine("Canceled");//這里將不會執(zhí)行輸出
});
//cancellationTokenSource.Cancel();
//var result = cancellationTokenRegistration.Unregister();//result = false
var result = cancellationTokenRegistration.Unregister();//result = true
cancellationTokenSource.Cancel();
上面提到，CancellationToken可以使用構造函數直接構造，同時可以傳入一個參數，表示當前的狀態(tài)，需要注意的是，CancellationToken的狀態(tài)最多可以改變一次，也就是從未取消變成已取消。
如果構造時傳入true，也就是說CancellationToken是已取消狀態(tài)，這個時候注冊的回調都會立即執(zhí)行：
CancellationToken cancellationToken = new CancellationToken(true);
cancellationToken.Register(() =>
{
Console.WriteLine("Canceled");//這里會立即執(zhí)行輸出Canceled
});
但如果構造時傳入的是false，說明CancellationToken處于未取消狀態(tài)，這時候注冊的回到都會處于一個待觸發(fā)狀態(tài)：
CancellationToken cancellationToken = new CancellationToken(false);
cancellationToken.Register(() =>
{
Console.WriteLine("Canceled");//這里不會立即執(zhí)行輸出
});
通過Register方法注冊的服務只會執(zhí)行一次！
但一般的，如果傳入false構造出來的CancellationToken，可以認為是不會觸發(fā)的，因為它沒有觸發(fā)的方法！所以一般的，我們都不會直接使用構造函數創(chuàng)建CancellationToken，而是使用CancellationTokenSource對象來獲取一個CancellationToken
CancellationTokenSource
CancellationTokenSource可以理解為CancellationToken的控制器，控制它什么時候變成取消狀態(tài)的一個對象，它有一個CancellationToken類型的屬性Token，只要CancellationTokenSource創(chuàng)建，這個Token也會被創(chuàng)建，同時Token會和這個CancellationTokenSource綁定
//表示Token是否已處于取消狀態(tài)
public bool IsCancellationRequested { get; }
//CancellationToken 對象
public CancellationToken Token { get; }
可以直接創(chuàng)建一個CancellationTokenSource對象，同時指定一個時間段，當過了這段時間后，CancellationTokenSource就會自動取消了。
CancellationTokenSource的取消有4個方法：
//立刻取消
public void Cancel();
//立刻取消
public void Cancel(bool throwOnFirstException);
//延遲指定時間后取消
public void CancelAfter(int millisecondsDelay);
//延遲指定時間后取消
public void CancelAfter(TimeSpan delay);
Cancel和兩個CancelAfter方法沒什么特別的，主要就是有一個延遲的效果，需要注意的是Cancel的兩個重載之間的區(qū)別。
首先，上面說道，CancellationToken狀態(tài)只能改變一次（從未取消變成已取消），當CancellationToken時已取消狀態(tài)時，每次往其中注冊的回調都會立刻執(zhí)行！當處于未取消狀態(tài)時，注冊進去的回調都會等待執(zhí)行。
需要注意的是，當在未取消狀態(tài)下注冊多個回調時，它們在執(zhí)行時是一個類似棧的結構順序，先注冊后執(zhí)行。
而CancellationToken的Register可以注冊多個回調，那他們可能都會拋出異常，throwOnFirstException參數表示在第一次報錯時的處理行為.
throwOnFirstException = true 表示立即拋出當前發(fā)生的異常，后續(xù)的回調將會取消執(zhí)行
CancellationTokenSource cancellationTokenSource = new CancellationTokenSource();
try
{
cancellationTokenSource.Token.Register(() =>
{
throw new Exception("1");
});
cancellationTokenSource.Token.Register(() =>
{
throw new Exception("2");//不會執(zhí)行
});
cancellationTokenSource.Cancel(true);
}
catch (Exception ex)
{
//ex is System.Exception("1")
}
throwOnFirstException = false 表示跳過當前回調的異常，繼續(xù)執(zhí)行生效的回調，等所有的回調執(zhí)行完成之后，再將所有的異常打包成一個System.AggregateException異常拋出來！
CancellationTokenSource cancellationTokenSource = new CancellationTokenSource();
try
{
cancellationTokenSource.Token.Register(() =>
{
throw new Exception("1");
});
cancellationTokenSource.Token.Register(() =>
{
throw new Exception("2");
});
cancellationTokenSource.Cancel(false);//相當于cancellationTokenSource.Cancel()
}
catch (Exception ex)
{
//ex is System.AggregateException:[Exception("2"),Exception("1")]
}
CancellationTokenSource還可以與其它CancellationToken關聯起來，生成一個新的CancellationToken，當其他CancellationToken取消時，會自動觸發(fā)當前的CancellationTokenSource執(zhí)行取消動作！
使用場景一
當我們創(chuàng)建異步操作時，可以傳入一個CancellationToken，當異步操作處于等待執(zhí)行狀態(tài)時，可以通過設置CancellationToken為取消狀態(tài)將異步操作取消執(zhí)行：
CancellationTokenSource cancellationTokenSource = new CancellationTokenSource();
var task = new Task(() =>
{
Thread.Sleep(1500);//執(zhí)行了2秒中代碼
Console.WriteLine("Execute Some Code");
}, cancellationTokenSource.Token);
task.Start();//啟動，等待調度執(zhí)行
//發(fā)現不對，可以取消task執(zhí)行
cancellationTokenSource.Cancel();
Thread.Sleep(1000);//等待1秒
Console.WriteLine("Task狀態(tài)：" + task.Status);//Canceled
但是經常的，我們的取消動作可能不會那么及時，如果異步已經執(zhí)行了，再執(zhí)行取消時無效的，這是就需要我們自己在異步委托中檢測了：
CancellationTokenSource cancellationTokenSource = new CancellationTokenSource();
var task = new Task(() =>
{
Thread.Sleep(1500);//執(zhí)行了2秒中代碼
cancellationTokenSource.Token.ThrowIfCancellationRequested();
Console.WriteLine("Execute Some Code");
}, cancellationTokenSource.Token);
task.Start();//啟動，等待調度執(zhí)行
Thread.Sleep(1000);////一段時間后發(fā)現不對，可以取消task執(zhí)行
cancellationTokenSource.Cancel();
Thread.Sleep(1000);//等待1秒
Console.WriteLine("Task狀態(tài)：" + task.Status);//Canceled
使用場景二
有時，我們希望在觸發(fā)某個時間后，可以執(zhí)行某些代碼功能，但是在異步環(huán)境下，我們不能保證那些要執(zhí)行的代碼是否已準備好了，比如我們有一個Close方法，當調用Close后表示是關閉狀態(tài)，如果我們相當程序處于關閉狀態(tài)時執(zhí)行一些通知，一般的，我們可能是想到采用事件模型，或者在Close方法傳入事件委托，或者采用一些諸如模板設計這樣的模型去實現：
class Demo
{
public void Close(Action callback)
{
//關閉
Thread.Sleep(3000);
callback?.Invoke();//執(zhí)行通知
}
}
或者
class Demo
{
public event Action Callback;
public void Close()
{
//關閉
Thread.Sleep(3000);
Callback?.Invoke();//執(zhí)行通知
}
}
但是這就有問題了，如果是傳入參數或者采用事件模型，因為前面說過了，如果在異步環(huán)境下，我們不能保證那些要執(zhí)行的代碼是否已準備好了，也許在執(zhí)行Close方法時，程序還未注冊回調。
這個時候就可以使用CancellationToken來解決這個問題：
主需要往Token屬性中注冊回調而無需關注Close什么時候執(zhí)行了
使用場景三
有時候，我們寫一個異步無限循環(huán)的方法去處理一些問題，而我們希望可以在方法外來停止它這個時候，我們就可以通過返回CancellationTokenSource來實現了：
public CancellationTokenSource Listen()
{
CancellationTokenSource cancellationTokenSource = new CancellationTokenSource();
//循環(huán)調度執(zhí)行
Task.Run(() =>
{
while (true)
{
cancellationTokenSource.Token.ThrowIfCancellationRequested();
//循環(huán)執(zhí)行一些操作
Thread.Sleep(1000);
Console.WriteLine("Run");
}
});
return cancellationTokenSource;
}
以上就是C# CancellationToken和CancellationTokenSource的用法詳解的詳細內容，更多關于C# CancellationToken和CancellationTokenSource的資料請關注腳本之家其它相關文章！
相關文章
這篇文章主要為大家詳細介紹了C#如何使用ffmpeg命令，分別實現給視頻添加圖片水印以及文字水印，文中的示例代講解詳細，感興趣的可以了解一下2023-01-01
這篇文章主要為大家詳細介紹了unity實現屏幕上寫字效果，具有一定的參考價值，感興趣的小伙伴們可以參考一下2019-07-07
這篇文章主要介紹了C#二進制序列化,實例分析了C#二進制序列化的方法,代碼中有較為詳盡的注釋說明,便于理解,需要的朋友可以參考下2015-05-05
梳排序算法是一種改進的冒泡排序算法,它通過調整冒泡排序的間隔來提高排序的效率,本文主要介紹了C#實現梳排序的使用示例,感興趣的可以了解一下2023-11-11
這篇文章主要為大家詳細介紹了C#如何智能AI五子棋游戲中的人工下棋操作以及對應的機器操作，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-11-11
本文詳細講解了C#中的Linq?to?JSON操作，文中通過示例代碼介紹的非常詳細。對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2022-06-06
這篇文章主要介紹了C#微信公眾號接口開發(fā)，靈活利用網頁授權、帶參數二維碼、模板消息，提升用戶體驗之完成用戶綁定個人微信及驗證碼獲取,需要的朋友可以參考下2015-07-07
C# 延遲Task.Delay()和Thread.Sleep()的具體使用
Thread.Sleep()是同步延遲,Task.Delay()是異步延遲,本文主要介紹了C# 延遲Task.Delay()和Thread.Sleep()的具體使用,文中通過示例代碼介紹的非常詳細,需要的朋友們下面隨著小編來一起學習學習吧2024-01-01
通常我們使用c#編寫的程序不會彈出這個提示，也就無法以管理員身分運行。微軟的操作系統使用微軟的產品方法當然是有的，通過app.manifest配置可以使程序打開的時候，彈出UAC提示需要得到允許才可以繼續(xù)，這樣就獲得了管理員的權限來執(zhí)行程序2015-01-01
詳解C#借助.NET框架中的XmlTextReader類讀取XML的方法
這篇文章主要介紹了詳解借助.NET框架中的XmlTextReader類讀取XML的方法,這種方式的執(zhí)行效率還是比較令人滿意的,需要的朋友可以參考下2016-04-04