深入解讀CancellationToken: .NET異步操作的控制操作方法
深入解讀CancellationToken：.NET異步操作的精準(zhǔn)控制
在.NET異步編程中，有效地控制異步操作的執(zhí)行過程至關(guān)重要。CancellationToken提供了一種優(yōu)雅的方式來取消或停止正在進(jìn)行的異步操作，確保資源的合理利用，提高應(yīng)用程序的穩(wěn)定性和響應(yīng)性，尤其適用于處理長時(shí)間運(yùn)行的異步任務(wù)。
一、技術(shù)背景
在異步編程模型里，一旦啟動(dòng)一個(gè)異步任務(wù)，如網(wǎng)絡(luò)請求、文件讀取或復(fù)雜計(jì)算，有時(shí)需要在任務(wù)完成前將其終止。例如，用戶在下載大文件時(shí)改變主意取消下載，或者一個(gè)Web請求等待異步任務(wù)響應(yīng)超時(shí)，需要終止任務(wù)以釋放資源。傳統(tǒng)方式實(shí)現(xiàn)異步操作的取消較為復(fù)雜，而CancellationToken為開發(fā)人員提供了一種標(biāo)準(zhǔn)、簡潔的機(jī)制，使得異步操作的取消變得更加容易和安全。
二、核心原理
CancellationToken本質(zhì)上是一個(gè)輕量級對象，用于向一個(gè)或多個(gè)異步操作發(fā)出取消信號。它通過一個(gè)布爾屬性IsCancellationRequested來表示是否已請求取消。當(dāng)IsCancellationRequested為true時(shí)，異步操作應(yīng)盡快停止執(zhí)行。
CancellationToken通常與CancellationTokenSource配合使用。CancellationTokenSource負(fù)責(zé)創(chuàng)建和管理CancellationToken實(shí)例。它提供了一個(gè)Cancel方法，調(diào)用該方法會(huì)將關(guān)聯(lián)的CancellationToken的IsCancellationRequested屬性設(shè)置為true，從而通知所有監(jiān)聽該令牌的異步操作進(jìn)行取消。
三、底層實(shí)現(xiàn)剖析
從底層實(shí)現(xiàn)看，CancellationToken內(nèi)部使用一個(gè)int類型的字段來存儲(chǔ)取消狀態(tài)。當(dāng)CancellationTokenSource的Cancel方法被調(diào)用時(shí)，會(huì)通過線程安全的方式修改這個(gè)字段的值，進(jìn)而影響IsCancellationRequested屬性的返回值。
在異步操作中，開發(fā)人員需要定期檢查CancellationToken的狀態(tài)。許多.NET框架中的異步方法已經(jīng)支持傳入CancellationToken參數(shù)，這些方法內(nèi)部會(huì)在適當(dāng)?shù)臅r(shí)機(jī)檢查令牌狀態(tài)。例如，Task.Delay方法的重載版本允許傳入CancellationToken，在延遲過程中，如果令牌被取消，Task.Delay會(huì)提前結(jié)束延遲并拋出OperationCanceledException。
以下是CancellationTokenSource部分核心源碼簡化示意：
public class CancellationTokenSource : CancellationTokenRegistration, IDisposable
{
private int _m_state;
public void Cancel()
{
// 通過Interlocked操作確保線程安全地修改取消狀態(tài)
Interlocked.Exchange(ref _m_state, 1);
}
}四、代碼示例
（一）基礎(chǔ)用法
- 功能說明：演示如何使用
CancellationToken取消一個(gè)簡單的異步延遲任務(wù)。
using System;
using System.Threading;
using System.Threading.Tasks;
class Program
{
static async Task Main()
{
var cancellationTokenSource = new CancellationTokenSource();
CancellationToken cancellationToken = cancellationTokenSource.Token;
Task delayTask = Task.Delay(TimeSpan.FromSeconds(5), cancellationToken);
// 模擬其他工作
await Task.Delay(TimeSpan.FromSeconds(2));
// 取消任務(wù)
cancellationTokenSource.Cancel();
try
{
await delayTask;
}
catch (OperationCanceledException)
{
Console.WriteLine("任務(wù)已取消");
}
}
}- 關(guān)鍵注釋：創(chuàng)建
CancellationTokenSource和對應(yīng)的CancellationToken。啟動(dòng)一個(gè)延遲5秒的任務(wù)，并在2秒后取消任務(wù)。通過try - catch塊捕獲OperationCanceledException以處理任務(wù)取消的情況。 - 運(yùn)行結(jié)果：輸出“任務(wù)已取消”。
（二）進(jìn)階場景
- 功能說明：在一個(gè)模擬的長時(shí)間運(yùn)行的計(jì)算任務(wù)中使用
CancellationToken進(jìn)行取消控制。
using System;
using System.Threading;
using System.Threading.Tasks;
class Program
{
static async Task LongRunningCalculationAsync(CancellationToken cancellationToken)
{
for (int i = 0; i < 1000000; i++)
{
if (cancellationToken.IsCancellationRequested)
{
Console.WriteLine("計(jì)算任務(wù)已取消");
return;
}
// 模擬計(jì)算
await Task.Delay(1);
}
Console.WriteLine("計(jì)算任務(wù)完成");
}
static async Task Main()
{
var cancellationTokenSource = new CancellationTokenSource();
CancellationToken cancellationToken = cancellationTokenSource.Token;
Task calculationTask = LongRunningCalculationAsync(cancellationToken);
// 模擬其他工作
await Task.Delay(TimeSpan.FromSeconds(2));
// 取消任務(wù)
cancellationTokenSource.Cancel();
try
{
await calculationTask;
}
catch (OperationCanceledException)
{
Console.WriteLine("任務(wù)已取消，異常捕獲");
}
}
}- 關(guān)鍵注釋：
LongRunningCalculationAsync方法模擬長時(shí)間運(yùn)行的計(jì)算任務(wù)，通過循環(huán)和await Task.Delay(1)模擬實(shí)際計(jì)算工作，并在每次循環(huán)中檢查CancellationToken狀態(tài)。在Main方法中啟動(dòng)計(jì)算任務(wù)，2秒后取消任務(wù)，并捕獲異常。 - 運(yùn)行結(jié)果：輸出“計(jì)算任務(wù)已取消”和“任務(wù)已取消，異常捕獲”。
（三）避坑案例
- 常見錯(cuò)誤：在異步操作中未正確檢查
CancellationToken狀態(tài)。
using System;
using System.Threading;
using System.Threading.Tasks;
class Program
{
static async Task IncorrectCalculationAsync(CancellationToken cancellationToken)
{
// 錯(cuò)誤：未檢查CancellationToken狀態(tài)
for (int i = 0; i < 1000000; i++)
{
await Task.Delay(1);
}
Console.WriteLine("計(jì)算任務(wù)完成");
}
static async Task Main()
{
var cancellationTokenSource = new CancellationTokenSource();
CancellationToken cancellationToken = cancellationTokenSource.Token;
Task calculationTask = IncorrectCalculationAsync(cancellationToken);
// 模擬其他工作
await Task.Delay(TimeSpan.FromSeconds(2));
// 取消任務(wù)
cancellationTokenSource.Cancel();
try
{
await calculationTask;
}
catch (OperationCanceledException)
{
Console.WriteLine("任務(wù)已取消，異常捕獲");
}
}
}- 錯(cuò)誤說明：
IncorrectCalculationAsync方法在循環(huán)中沒有檢查CancellationToken狀態(tài)，即使調(diào)用了Cancel方法，任務(wù)也不會(huì)響應(yīng)取消請求，會(huì)繼續(xù)執(zhí)行直到完成。 - 修復(fù)方案：在循環(huán)中添加對
CancellationToken狀態(tài)的檢查。
using System;
using System.Threading;
using System.Threading.Tasks;
class Program
{
static async Task CorrectCalculationAsync(CancellationToken cancellationToken)
{
for (int i = 0; i < 1000000; i++)
{
if (cancellationToken.IsCancellationRequested)
{
Console.WriteLine("計(jì)算任務(wù)已取消");
return;
}
await Task.Delay(1);
}
Console.WriteLine("計(jì)算任務(wù)完成");
}
static async Task Main()
{
var cancellationTokenSource = new CancellationTokenSource();
CancellationToken cancellationToken = cancellationTokenSource.Token;
Task calculationTask = CorrectCalculationAsync(cancellationToken);
// 模擬其他工作
await Task.Delay(TimeSpan.FromSeconds(2));
// 取消任務(wù)
cancellationTokenSource.Cancel();
try
{
await calculationTask;
}
catch (OperationCanceledException)
{
Console.WriteLine("任務(wù)已取消，異常捕獲");
}
}
}- 運(yùn)行結(jié)果：輸出“計(jì)算任務(wù)已取消”和“任務(wù)已取消，異常捕獲”。
五、性能對比/實(shí)踐建議
- 性能對比：使用
CancellationToken帶來的性能開銷極小，因?yàn)樗饕蕾嚭唵蔚牟紶栔禉z查和線程安全的狀態(tài)修改操作。相較于不使用CancellationToken而讓任務(wù)無限制運(yùn)行直至完成，適時(shí)取消任務(wù)可以顯著節(jié)省資源，提高系統(tǒng)的整體性能和響應(yīng)速度。 - 實(shí)踐建議：
- 在編寫長時(shí)間運(yùn)行的異步任務(wù)時(shí)，始終考慮接受
CancellationToken參數(shù)，以便調(diào)用者可以在需要時(shí)取消任務(wù)。 - 定期在異步任務(wù)的關(guān)鍵節(jié)點(diǎn)檢查
CancellationToken狀態(tài)，確保任務(wù)能及時(shí)響應(yīng)取消請求。但檢查頻率不宜過高，以免影響性能。 - 注意處理
OperationCanceledException，確保在任務(wù)取消時(shí)資源得到正確清理，如關(guān)閉文件句柄、釋放網(wǎng)絡(luò)連接等。
- 在編寫長時(shí)間運(yùn)行的異步任務(wù)時(shí)，始終考慮接受
六、常見問題解答
（一）一個(gè)CancellationToken能否用于多個(gè)異步任務(wù)？
可以，一個(gè)CancellationToken可以傳遞給多個(gè)異步任務(wù)，當(dāng)調(diào)用CancellationTokenSource的Cancel方法時(shí)，所有監(jiān)聽該CancellationToken的異步任務(wù)都會(huì)收到取消信號。
（二）CancellationToken如何與async/await配合使用？
在async方法中，將CancellationToken作為參數(shù)傳遞，并在方法內(nèi)部適當(dāng)位置檢查IsCancellationRequested屬性。當(dāng)使用await等待異步操作時(shí)，如果操作支持CancellationToken，可將令牌傳遞進(jìn)去，這樣在令牌取消時(shí)，異步操作會(huì)提前結(jié)束并拋出OperationCanceledException。
CancellationToken為.NET異步編程中的任務(wù)取消提供了一種簡潔且高效的機(jī)制。在實(shí)際開發(fā)中，合理運(yùn)用CancellationToken能夠有效提升應(yīng)用程序的穩(wěn)定性和響應(yīng)性，避免資源浪費(fèi)。隨著.NET平臺的發(fā)展，預(yù)計(jì)CancellationToken相關(guān)的功能和使用場景將進(jìn)一步優(yōu)化和拓展。
到此這篇關(guān)于深入解讀CancellationToken .NET異步操作的精準(zhǔn)控制的文章就介紹到這了,更多相關(guān).net cancellationtoken異步內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
ASP.NET Sql Server安裝向?qū)В╝spnet_regsql.exe）錯(cuò)誤解決一例
這個(gè)程序是注冊網(wǎng)站的數(shù)據(jù)庫，從而提供Membership , Role , Profile 等等諸多功能和管理權(quán)限的控件的使用。2010-03-03
mysql安裝后.net程序運(yùn)行出錯(cuò)的解決方法
這篇文章主要給大家介紹了關(guān)于mysql安裝后.net程序運(yùn)行出錯(cuò)的解決方法，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧。2018-02-02
ASP.NET MVC5驗(yàn)證系列之Fluent Validation
這篇文章主要為大家詳細(xì)介紹了ASP.NET MVC5驗(yàn)證系列之Fluent Validation，感興趣的小伙伴們可以參考一下2016-07-07
Asp.net生成Excel文件并下載（更新：解決使用迅雷下載頁面而不是文件的問題）
Asp.net生成Excel文件并下載（更新：解決使用迅雷下載頁面而不是文件的問題）2012-01-01
ASP.NET服務(wù)器端控件RadioButtonList，DropDownList，CheckBoxList的取值、賦值
這三個(gè)控件都有一個(gè)Items集合，可以用 RepeatLayout 和 RepeatDirection 屬性來控制列表的呈現(xiàn)形式2013-10-10
FileUpload使用Javascript檢查擴(kuò)展名是否有效實(shí)現(xiàn)思路
在JavaScript獲取FileUpload控件的文件路徑，并取得路徑中的文件擴(kuò)展名,再與陣列中的擴(kuò)展名比較，如果存在，說明上傳的文件是有效的，反之無效,感興趣的朋友可以了解下，或許對你有所幫助2013-02-02
這篇文章主要介紹了c# rabbitmq 簡單收發(fā)消息的示例代碼，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-08-08
詳解如何在ASP.NET Core中應(yīng)用Entity Framework
本篇文章主要介紹了如何在ASP.NET Core中應(yīng)用Entity Framework，具有一定的參考價(jià)值，有興趣的可以一起了解一下。2016-12-12
Asp.Net Core對接釘釘群機(jī)器人的完整步驟記錄
這篇文章主要給大家介紹了關(guān)于Asp.Net Core對接釘釘群機(jī)器人的相關(guān)資料，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面來一起學(xué)習(xí)學(xué)習(xí)吧2019-03-03
通過設(shè)置form的target屬性同樣可以讓Response.Rederect所指向的url在新的窗口打開，下面為大家介紹三種具體的實(shí)現(xiàn)方法2013-10-10