.NET中如何使用CancellationToken取消异步操作_异步操作取消机制详解

来源:这里教程网 时间:2026-02-21 17:31:22 作者:

在 .NET 中,CancellationToken 是用于协作式取消异步操作的核心机制。它允许你请求取消长时间运行或可中断的任务,而任务本身决定是否以及何时响应取消请求。这种设计避免了强制终止线程带来的资源泄漏或状态不一致问题。

什么是 CancellationToken?

CancellationToken 是一个轻量级结构,表示可能发生的取消通知。它通常由 CancellationTokenSource 创建和管理。当调用

CancellationTokenSource.Cancel()
方法时,所有关联的 token 会进入“已取消”状态,并触发注册的回调函数(如果有)。

关键点:

取消是协作式的 —— 异步方法必须主动检查 token 状态。 一个 token 只能被取消一次,之后状态永久为“已取消”。 不能强制终止正在执行的操作,只能通知其尝试停止。

如何在异步方法中使用 CancellationToken

大多数内置的异步方法(如

HttpClient.GetAsync
StreamReader.ReadLineAsync
)都接受一个
CancellationToken
参数。你只需将 token 传入即可启用取消支持。

示例:使用 HttpClient 发起可取消的请求

using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(5)); // 5秒后自动取消
try
{
    using var client = new HttpClient();
    var response = await client.GetAsync("https://httpbin.org/delay/10", cts.Token);
    Console.WriteLine(await response.Content.ReadAsStringAsync());
}
catch (OperationCanceledException ex)
{
    Console.WriteLine("请求被取消:" + ex.Message);
}

说明:

CancellationTokenSource
控制生命周期。
设置超时时间后,超过该时间自动触发取消。 捕获
OperationCanceledException
处理取消情形。

手动检查取消令牌

如果你编写自定义异步逻辑(如循环处理数据),需要定期检查 token 是否已被请求取消。

示例:模拟长时间任务并监听取消

public async Task LongRunningProcessAsync(CancellationToken token)
{
    for (int i = 0; i < 100; i++)
    {
        // 模拟工作
        await Task.Delay(100, token); // Delay 支持 token
        // 手动检查(可选)
        token.ThrowIfCancellationRequested();
        Console.WriteLine($"处理进度: {i + 1}%");
    }
}

建议做法:

在每个循环迭代中检查 token。 调用
ThrowIfCancellationRequested()
抛出标准异常。
或将 token 传递给支持它的 API(如
Task.Delay
、EF Core 查询等)。

组合多个取消条件

你可以通过

CancellationTokenSource.CreateLinkedTokenSource
合并多个 token,实现更复杂的取消策略。

例如:同时监听用户取消和超时

var cts1 = new CancellationTokenSource();
var cts2 = new CancellationTokenSource(TimeSpan.FromSeconds(3));
using var linkedCts = CancellationTokenSource.CreateLinkedTokenSource(cts1.Token, cts2.Token);
try
{
    await LongRunningProcessAsync(linkedCts.Token);
}
catch (OperationCanceledException)
{
    if (cts2.IsCancellationRequested)
        Console.WriteLine("操作因超时被取消");
    else
        Console.WriteLine("操作被用户取消");
}

这在 Web API 中很常见:客户端断开连接 + 请求超时双重控制。

基本上就这些。合理使用 CancellationToken 能显著提升应用的响应性和资源利用率,尤其是在高并发或长时间任务场景中。

相关推荐

热文推荐