news 2026/6/15 16:32:07

异步编程---异步取消机制CancellationToken

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
异步编程---异步取消机制CancellationToken

异步代码不加取消机制?犹如开车没有刹车

没有取消机制的异步代码,就像开车没有刹车。表面看似没问题,直到你发现应用仍在疯狂运行、消耗内存、执着地完成早已无人需要的工作。这不是健壮性,而是披着高效外衣的资源浪费。
如果你仍以“没有取消令牌也能运行”为由跳过它们,那你写的就不是健壮的异步代码——你写的是为所欲为的代码。现在可能没问题,但迟早会出事。
如果你曾点过毫无反应的取消按钮,你就会明白:这个话题值得掌握。
(第二部分现已发布)


什么是 CancellationToken?
本质上,CancellationToken 只是一个信号——一个轻量级对象,用于告知异步代码:“该停止了。”但令牌本身并不执行取消操作,它只负责接收信号。
发送信号的是 CancellationTokenSource。你创建源对象,从中获取令牌,并将令牌传递给任何需要支持取消的方法。
基本结构

usingvarcts=newCancellationTokenSource();CancellationTokentoken=cts.Token;// 可以在其他地方取消令牌:cts.Cancel();

可以这样理解:

  • CancellationTokenSource = 控制器
  • CancellationToken = 广播信号
  • 异步方法 = 监听器(收到信号后自愿停止)

如何在异步方法中传递和使用令牌
几乎所有规范的 .NET API 都接受可选 CancellationToken 参数,这意味着你的方法也应该如此。
定义带令牌参数的方法

publicasyncTaskDoWorkAsync(CancellationTokencancellationToken){for(inti=0;i<10;i++){cancellationToken.ThrowIfCancellationRequested();Console.WriteLine($"Working...{i}");awaitTask.Delay(500,cancellationToken);}}

在调用链中传递令牌

usingvarcts=newCancellationTokenSource();Tasktask=DoWorkAsync(cts.Token);// 2秒后取消cts.CancelAfter(TimeSpan.FromSeconds(2));

注意:

  • ThrowIfCancellationRequested() 用于响应取消信号
  • Task.Delay(…) 也支持令牌,因此取消操作可以中断等待
  • 必须将令牌传递给每个可取消操作
  • 判断IsCancellationRequested 用于判断令牌是否被取消
    以下是一个支持取消的简单异步方法:
publicasyncTask<string>DownloadAsync(stringurl,CancellationTokencancellationToken){usingvarhttpClient=newHttpClient();varresponse=awaithttpClient.GetAsync(url,cancellationToken);returnawaitresponse.Content.ReadAsStringAsync();}

传递令牌让被调用方有权选择退出。调用方式如下:

varcts=newCancellationTokenSource(TimeSpan.FromSeconds(5));try{varcontent=awaitDownloadAsync("https://example.com",cts.Token);Console.WriteLine("Download succeeded!");}catch(OperationCanceledException){Console.WriteLine("Download cancelled.");}

必须单独处理 OperationCanceledException,以区分操作失败和取消。

判断IsCancellationRequested
在执行循环任务的时候可以通过IsCancellationRequested判断是否被取消任务来进行退出,这样可以不用抛出异常。

// 4. 主动判断是否取消privateasyncTaskActiveCancellationExample(){usingvarcts=newCancellationTokenSource();CancellationTokentoken=cts.Token;// 5秒触发取消cts.CancelAfter(TimeSpan.FromSeconds(5));// 启动工作任务Task<bool>workTask=DoWorkNoErrorAsync(token);try{varres=awaitworkTask;Console.WriteLine($"工作已完成:{res}");}catch(OperationCanceledException){Console.WriteLine("工作已被取消");}}privateasyncTask<bool>DoWorkNoErrorAsync(CancellationTokencancellationToken){for(inti=0;i<10;i++){// 检查是否已请求取消if(cancellationToken.IsCancellationRequested){// 可选:添加取消前的清理逻辑(如释放资源)returnfalse;}Console.WriteLine($"工作中...{i}");// 捕获Delay期间的取消异常awaitTask.Delay(500);}returntrue;}---

忽略取消机制带来的隐藏缺陷
问题在这里变得严重。忽略取消令牌不仅是错过优化,更是滋生难以复现缺陷的温床:

  1. 僵尸任务
    用户取消了操作,但任务仍在后台运行:写入内存、更新状态,甚至可能随后抛出错误。
  2. 应用关闭延迟
    不可取消的任务会阻塞优雅关闭,迫使你依赖 Environment.Exit(1) 而非干净的退出钩子。
  3. 内存泄漏
    不释放 CancellationTokenSource 或在循环中忽略取消,可能导致内存持有时间远超预期。
  4. 测试无限挂起
    依赖异步操作但无取消机制的测试没有退出策略,CI 流水线可能因小错误卡住 30 分钟。
    忽略取消不仅是懒惰,更是危险。

为何应该使用取消令牌
因为你的代码不是孤立运行的。
异步操作发生在某些生命周期内:

  • 用户离开页面时
  • 后台服务关闭时
  • •UI 发出停止加载数据的信号时
    如果代码忽略取消:
  • 浪费计算资源
  • 迫使调用方使用 Hack 手段(超时、强制终止)
  • 导致测试脆弱性
    如果你正在构建可复用 API,标准更高。使用者期望能传递取消令牌。如果方法签名不支持,会降低代码在实际系统中的可用性。

示例:协作式控制台应用publicstaticasyncTaskMain(){usingvarcts=newCancellationTokenSource();Console.CancelKeyPress+=(s,e)=>{e.Cancel=true;cts.Cancel();};try{awaitDoWorkAsync(cts.Token);Console.WriteLine("Work completed successfully.");}catch(OperationCanceledException){Console.WriteLine("Work was cancelled.");}}staticasyncTaskDoWorkAsync(CancellationTokentoken){for(inti=0;i<10;i++){token.ThrowIfCancellationRequested();Console.WriteLine($"Working...{i}");awaitTask.Delay(1000,token);}}

按 Ctrl+C 即可取消。这是真实场景的行为——应用按指令退出,而不是随心所欲。


忽略取消的代价
许多开发者将 CancellationToken 视为可选参数。他们将其塞入方法签名以满足分析器或库规范,却从不实际使用。这种心态会导致应用无响应、关闭缓慢、CPU 周期浪费,甚至内存泄漏。
理解取消机制不仅是编写防御性代码,更是编写专业代码:尊重用户时间、节约系统资源、在压力下保持可预测行为。
本文奠定了基础:令牌是什么、如何传递、为何重要,以及忘记使用会如何导致微妙而痛苦的缺陷。

实例的代码已经上传到Gitee:https://gitee.com/panwangvie/PwjBlogExamples/blob/master/AsyncCodeDemo/CancellationExamples.cs

版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/6/15 11:54:48

Langchain-Chatchat部署常见问题及解决方案汇总

Langchain-Chatchat 部署常见问题及解决方案深度解析 在企业对数据隐私要求日益严格的今天&#xff0c;将大型语言模型&#xff08;LLM&#xff09;部署于本地环境已不再是“可选项”&#xff0c;而是金融、医疗、法律等高合规性行业落地智能问答系统的前提条件。公有云服务虽…

作者头像 李华
网站建设 2026/6/15 2:12:54

Pyecharts终极指南:如何快速构建专业级数据可视化应用

Pyecharts终极指南&#xff1a;如何快速构建专业级数据可视化应用 【免费下载链接】pyecharts &#x1f3a8; Python Echarts Plotting Library 项目地址: https://gitcode.com/gh_mirrors/py/pyecharts 在大数据时代&#xff0c;数据可视化已成为决策分析的关键环节。P…

作者头像 李华
网站建设 2026/6/15 12:40:45

VVdeC:终极H.266/VVC视频解码器完整指南

VVdeC&#xff1a;终极H.266/VVC视频解码器完整指南 【免费下载链接】vvdec VVdeC, the Fraunhofer Versatile Video Decoder 项目地址: https://gitcode.com/gh_mirrors/vv/vvdec VVdeC&#xff08;Fraunhofer Versatile Video Decoder&#xff09;是一款专为高效软件实…

作者头像 李华
网站建设 2026/6/15 6:01:38

SharpCompress魔法手册:解锁C压缩解压的无限可能

SharpCompress魔法手册&#xff1a;解锁C#压缩解压的无限可能 【免费下载链接】sharpcompress SharpCompress is a fully managed C# library to deal with many compression types and formats. 项目地址: https://gitcode.com/gh_mirrors/sh/sharpcompress 还在为复杂…

作者头像 李华
网站建设 2026/6/15 10:28:04

WAN2.2-14B-Rapid-AllInOne:终极AI视频生成完整攻略

WAN2.2-14B-Rapid-AllInOne&#xff1a;终极AI视频生成完整攻略 【免费下载链接】WAN2.2-14B-Rapid-AllInOne 项目地址: https://ai.gitcode.com/hf_mirrors/Phr00t/WAN2.2-14B-Rapid-AllInOne 2025年AI视频生成技术迎来重大突破&#xff0c;WAN2.2-14B-Rapid-AllInOne…

作者头像 李华
网站建设 2026/6/15 13:38:38

如何选择KernelSU模式:GKI与LKM的完整对比指南

如何选择KernelSU模式&#xff1a;GKI与LKM的完整对比指南 【免费下载链接】KernelSU A Kernel based root solution for Android 项目地址: https://gitcode.com/GitHub_Trending/ke/KernelSU KernelSU是一个基于内核的Android root解决方案&#xff0c;为用户提供了两…

作者头像 李华