在C#中,可以使用CancellationToken
和CancellationTokenSource
来实现任务的取消。下面是一个简单的示例:
using System;
using System.Threading;
using System.Threading.Tasks;
class Program
{
static async Task Main(string[] args)
{
// 创建一个CancellationTokenSource对象,用于发送取消信号
CancellationTokenSource cts = new CancellationTokenSource();
// 将CancellationToken传递给任务
Task task = Task.Run(() => DoWork(cts.Token), cts.Token);
// 延迟500毫秒后取消任务
await Task.Delay(500);
cts.Cancel();
try
{
// 等待任务完成
await task;
}
catch (OperationCanceledException)
{
Console.WriteLine("任务已被取消");
}
}
static void DoWork(CancellationToken token)
{
for (int i = 0; i < 10; i++)
{
// 检查是否收到取消信号
if (token.IsCancellationRequested)
{
Console.WriteLine($"任务取消,当前进度:{i}");
token.ThrowIfCancellationRequested();
}
// 模拟工作
Thread.Sleep(100);
}
Console.WriteLine("任务完成");
}
}
在这个示例中,我们创建了一个CancellationTokenSource
对象,并将其CancellationToken
传递给任务。在任务中,我们定期检查CancellationToken
的IsCancellationRequested
属性,以确定是否收到取消信号。如果收到取消信号,我们可以选择抛出OperationCanceledException
或者执行其他清理操作。
在主函数中,我们使用Task.Delay
延迟500毫秒后调用cts.Cancel()
方法发送取消信号。然后我们等待任务完成,并捕获OperationCanceledException
异常以处理任务取消的情况。