在C#中,可以使用CancellationToken
和CancellationTokenSource
來實現(xiàn)任務(wù)的取消。下面是一個簡單的示例:
using System;
using System.Threading;
using System.Threading.Tasks;
class Program
{
static async Task Main(string[] args)
{
// 創(chuàng)建一個CancellationTokenSource對象,用于發(fā)送取消信號
CancellationTokenSource cts = new CancellationTokenSource();
// 將CancellationToken傳遞給任務(wù)
Task task = Task.Run(() => DoWork(cts.Token), cts.Token);
// 延遲500毫秒后取消任務(wù)
await Task.Delay(500);
cts.Cancel();
try
{
// 等待任務(wù)完成
await task;
}
catch (OperationCanceledException)
{
Console.WriteLine("任務(wù)已被取消");
}
}
static void DoWork(CancellationToken token)
{
for (int i = 0; i < 10; i++)
{
// 檢查是否收到取消信號
if (token.IsCancellationRequested)
{
Console.WriteLine($"任務(wù)取消,當前進度:{i}");
token.ThrowIfCancellationRequested();
}
// 模擬工作
Thread.Sleep(100);
}
Console.WriteLine("任務(wù)完成");
}
}
在這個示例中,我們創(chuàng)建了一個CancellationTokenSource
對象,并將其CancellationToken
傳遞給任務(wù)。在任務(wù)中,我們定期檢查CancellationToken
的IsCancellationRequested
屬性,以確定是否收到取消信號。如果收到取消信號,我們可以選擇拋出OperationCanceledException
或者執(zhí)行其他清理操作。
在主函數(shù)中,我們使用Task.Delay
延遲500毫秒后調(diào)用cts.Cancel()
方法發(fā)送取消信號。然后我們等待任務(wù)完成,并捕獲OperationCanceledException
異常以處理任務(wù)取消的情況。