C#的CancellationTokenSource如何取消任务?

C#中任务取消的协作式原理是通过CancellationTokenSource发送取消信号,任务需主动检查CancellationToken或调用ThrowIfCancellationRequested响应,而非强制终止。

c#的cancellationtokensource如何取消任务?

C#中,

CancellationTokenSource

提供了一种优雅且协作式的机制来取消正在执行的任务。它不是强制中断,而是向任务发出“请停止”的信号,任务本身需要主动监听并响应这个信号。这就像你给一个正在工作的同事发消息说“你手头的事可以先放下了”,至于他什么时候放下,以什么方式放下,最终还是由他自己决定和执行。

要实现任务取消,我们通常会遵循一套流程。首先,你需要创建一个

CancellationTokenSource

的实例。这个对象就是取消操作的“发令员”。

var cts = new CancellationTokenSource();

接着,从

CancellationTokenSource

中获取一个

CancellationToken

。这个

Token

就像一张通行证,你需要把它传递给你想要取消的任务或方法。

CancellationToken token = cts.Token;

在你的任务或长时间运行的方法内部,你需要周期性地检查这个

Token

的状态。最直接的方式是检查

token.IsCancellationRequested

属性。

// 示例:一个长时间运行的任务Task.Run(() =>{    while (true)    {        if (token.IsCancellationRequested)        {            Console.WriteLine("任务收到取消请求,准备退出...");            // 在这里执行一些清理工作            break; // 退出循环        }        Console.WriteLine("任务正在执行...");        Thread.Sleep(500); // 模拟耗时操作    }}, token); // 也可以将token传递给Task.Run,这样如果token被取消,Task会进入Canceled状态

更推荐的做法是使用

token.ThrowIfCancellationRequested()

方法。当

Token

被取消时,这个方法会立即抛出一个

OperationCanceledException

。这种方式能更简洁、更符合异常处理范式地中断任务执行。

Task.Run(() =>{    try    {        for (int i = 0; i < 100; i++)        {            token.ThrowIfCancellationRequested(); // 如果取消,这里会抛异常            Console.WriteLine($"任务执行到第 {i} 步...");            Thread.Sleep(200);        }    }    catch (OperationCanceledException)    {        Console.WriteLine("任务因取消请求而终止。");    }}, token);

当你想取消任务时,只需调用

CancellationTokenSource

实例的

Cancel()

方法即可。

cts.Cancel();

最后,别忘了

CancellationTokenSource

实现了

IDisposable

接口。用完之后,最好调用

Dispose()

方法释放资源,或者更常见的做法是将其包裹在

using

语句中。

using (var cts = new CancellationTokenSource()) { /* ... */ }

C#中任务取消的协作式原理是什么?

我们谈到

CancellationTokenSource

,很多人会把它想象成一个“急停按钮”,一按任务就立马停了。但实际上,它更像是一个“请示停止”的信号灯。这背后的核心理念就是“协作式取消”。与过去

Thread.Abort()

那种粗暴、不安全的强制终止方式(现在已经废弃,也不推荐使用)截然不同,协作式取消要求被取消的任务本身要“配合”。

简单来说,

CancellationTokenSource

发出的

CancellationToken

只是一个请求,一个意图。任务代码内部必须主动去检查这个

Token

的状态,并根据

IsCancellationRequested

的值或者

ThrowIfCancellationRequested()

抛出的异常来决定何时、何地停止执行。这种设计,在我看来,是C#并发编程中一个非常成熟和负责任的选择。它避免了强制终止可能带来的各种问题,比如资源泄露(文件句柄、网络连接没来得及关闭)、数据损坏(操作进行到一半,数据处于不一致状态),以及死锁等难以预料的副作用。

通过协作,任务可以在收到取消请求时,有机会完成当前的原子操作、释放已持有的资源、回滚未提交的事务,或者至少记录下当前状态,然后才优雅地退出。这给了开发者极大的控制权,确保了程序的健壮性和稳定性。当然,这也意味着如果你的任务代码里没有检查

CancellationToken

,那么即便你调用了

Cancel()

,任务也可能会继续运行,直到它自然结束。所以,开发者在编写长时间运行或可取消的任务时,肩负着主动响应取消请求的责任。

在异步方法中如何正确捕获和处理OperationCanceledException?

CancellationToken

被取消,并且你的代码中调用了

ThrowIfCancellationRequested()

,或者你将

CancellationToken

传递给了

Task.Run

HttpClient.GetAsync

等支持取消的方法,那么当取消发生时,通常会抛出

OperationCanceledException

。处理这种异常,我觉得需要一些特别的思考,因为它和我们平时处理的“错误”不太一样。

OperationCanceledException

并不是一个指示程序出错的信号,它更多的是一种预期的控制流。它表明任务按照设计被取消了,这通常不是一个需要崩溃或记录为严重错误的情况。因此,在

async/await

结构中,我们应该用

try-catch

块来捕获它,并进行适当的处理,而不是让它传播出去导致程序崩溃。

看一个例子:

public async Task DoSomethingCancellableAsync(CancellationToken token){    try    {        Console.WriteLine("异步任务开始...");        for (int i = 0; i < 10; i++)        {            token.ThrowIfCancellationRequested(); // 检查取消            await Task.Delay(500, token); // 这里的Task.Delay也支持取消            Console.WriteLine($"异步任务进行到 {i + 1} 步。");        }        Console.WriteLine("异步任务完成。");    }    catch (OperationCanceledException ex)    {        // 这是一个预期的取消,不是错误        Console.WriteLine($"异步任务被取消了: {ex.Message}");        // 在这里可以进行一些清理工作,比如关闭文件、释放网络连接等        // 如果需要,可以重新抛出,但通常不需要        // throw;     }    catch (Exception ex)    {        // 处理其他非取消引起的错误        Console.WriteLine($"异步任务发生未知错误: {ex.Message}");    }    finally

以上就是C#的CancellationTokenSource如何取消任务?的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1439667.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年12月17日 16:24:07
下一篇 2025年12月17日 16:24:14

相关推荐

  • C#的Dictionary是如何存储键值对的?

    哈希冲突是通过链式法解决的。1. dictionary内部使用桶数组,每个桶关联一个链表结构;2. 当不同键映射到同一桶时,键值对被添加到该桶链表的尾部;3. 查找时先通过哈希码定位桶,再遍历链表用equals()方法精确匹配键;4. 这种机制确保冲突时数据不会丢失,但会降低查找效率,因此需要好的哈…

    好文分享 2025年12月17日
    000
  • C#交互式教程环境搭建

    搭建c#交互式教程环境的解决方案是安装.net sdk、jupyter notebook和.net interactive工具,并将其注册为jupyter内核。1. 安装.net sdk并验证版本;2. 通过pip安装jupyter notebook;3. 使用dotnet命令全局安装.net in…

    2025年12月17日
    000
  • WPF中的行为Behaviors应该怎么使用?

    Behaviors通过附加交互逻辑到UI元素,解决了WPF中Code-behind臃肿、UI逻辑难复用及MVVM解耦难题,实现可复用、可测试的声明式交互,提升代码整洁性与维护性。 Behaviors提供了一种优雅的方式,让我们可以在不修改或继承现有控件的情况下,为它们添加可复用的交互逻辑。本质上,它…

    2025年12月17日
    000
  • StackOverflowException能捕获吗?如何避免递归溢出?

    无法直接捕获stackoverflowexception,因其属于系统级致命错误,程序通常直接崩溃;2. 避免栈溢出的核心是优化递归逻辑或转为迭代;3. 将递归转换为迭代可有效控制内存使用,避免栈帧无限增长;4. 尾递归优化仅在部分语言中有效,java和python不支持;5. 可通过深度计数器限制…

    2025年12月17日
    000
  • C#的try-catch-finally语句如何捕获异常?最佳实践是什么?

    try-catch-finally用于处理C#运行时异常,try包裹可能出错的代码,catch捕获并处理特定异常,finally确保资源释放等收尾操作始终执行,适用于文件操作、网络请求等易受外部影响的场景,应避免吞噬异常、优先捕获具体异常,并结合using语句简化资源管理,提升代码健壮性。 说起C#…

    2025年12月17日
    000
  • C#的SerializationException是什么?序列化失败处理

    c#中的serializationexception通常由类未标记[serializable]特性、包含无法序列化的成员、版本不兼容或权限不足引起;2. 解决方案包括为类添加[serializable]标签、使用[nonserialized]标记不可序列化字段、实现iserializable接口处理…

    2025年12月17日
    000
  • C#的匿名方法是什么?如何使用?

    匿名方法是C#中无需命名即可定义委托逻辑的特性,简化事件处理与LINQ操作,支持闭包并可捕获外部变量,但需注意性能影响,推荐在一次性逻辑中使用以提升代码简洁性与可读性。 C#的匿名方法本质上是一种没有名字的方法。它允许你直接在代码中定义一个方法,而不需要像传统方法那样先声明,然后再使用。这在处理委托…

    2025年12月17日
    000
  • WPF中的依赖属性与普通属性区别在哪?

    依赖属性是WPF为实现数据绑定、样式、动画等高级功能而设计的特殊属性,其值存储在DependencyObject的全局字典中并支持优先级解析和自动通知,而普通CLR属性仅存储在对象字段中且无内置通知机制;依赖属性适用于UI相关、需绑定或样式的场景,普通属性适用于数据模型和内部状态管理。 WPF中的依…

    2025年12月17日
    000
  • C#的readonly关键字和const有什么区别?何时使用?

    const是编译时常量,值在编译时确定且所有实例共享,适用于如PI等固定值;readonly是运行时常量,可在构造函数中初始化,每个实例可不同,适用于创建时间等需运行时赋值的场景。 readonly 和 const 都是C#中用于声明不可变性的关键字,但它们在编译时和运行时行为以及适用场景上存在显著…

    2025年12月17日
    000
  • C#的BackgroundWorker组件怎么处理耗时任务?

    BackgroundWorker通过事件机制在后台线程执行耗时任务,避免UI阻塞,其DoWork、ProgressChanged和RunWorkerCompleted事件分别处理工作、进度更新和完成操作,确保UI更新安全;相比async/await,它更适合简单独立任务,而async/await更适…

    2025年12月17日
    000
  • ASP.NET Core中的应用程序模型是什么?如何理解?

    答案:ASP.NET Core应用程序模型是框架用于描述和管理应用中可路由组件的元数据集合,它在启动时通过IApplicationModelProvider扫描控制器、动作等元素,构建成包含路由、过滤器、绑定信息的ControllerModel、ActionModel等对象,最终形成Applicat…

    2025年12月17日
    000
  • C#的Regex类如何实现正则表达式匹配?

    使用regex时常见陷阱包括灾难性回溯、特殊字符未转义导致匹配错误,以及在循环中重复创建regex对象影响性能;2. 性能优化建议:避免重复创建实例,高频使用时采用regexoptions.compiled,优先使用静态方法利用内置缓存,合理设计贪婪与非贪婪匹配;3. 提取数据时可通过match.g…

    2025年12月17日
    000
  • C#的异步流是什么?如何使用?

    异步流是C#中用于处理逐步到达数据序列的机制,它是IEnumerable的异步版本,通过IAsyncEnumerable实现非阻塞式逐项数据消费,适用于网络请求或大数据读取场景。 C#里的异步流,说白了,就是让你能以一种非常优雅的方式去处理那些不是一下子就能全部拿到的数据序列。它就像是传统同步集合(…

    2025年12月17日
    000
  • C#的Dispatcher.Invoke方法有什么作用?

    Dispatcher.Invoke用于将UI更新操作同步调度到UI线程执行,解决跨线程操作异常。它通过将委托放入UI线程消息队列并阻塞调用线程,确保UI更新由UI线程完成,保障线程安全。与异步的BeginInvoke不同,Invoke会等待操作完成,适用于需确保UI更新完成或获取返回值的场景,但可能…

    2025年12月17日
    000
  • C#的XAML语言在WPF中的作用是什么?

    xaml在wpf中用于声明式定义用户界面,c#负责逻辑处理,二者协同构建交互式应用;xaml通过直观的语法简化界面设计,支持拖拽控件和实时预览,提升开发效率;数据绑定通过binding标记实现界面与c#数据源的自动同步,减少手动更新ui的代码;可在c#中通过findname获取并修改xaml控件属性…

    2025年12月17日
    000
  • ASP.NET Core中的应用程序初始化是什么?如何配置?

    ASP.NET Core应用程序初始化需配置服务与中间件,核心在Program.cs和Startup.cs中完成。IHost为通用主机,IWebHost继承自IHost并专用于Web应用。通过CreateHostBuilder配置主机,Startup类中ConfigureServices注册服务,C…

    2025年12月17日
    000
  • C#的异步流在桌面开发中怎么应用?

    C#异步流通过IAsyncEnumerable和await foreach实现数据的流式处理,使桌面应用能在数据生成的同时逐步更新UI,避免卡顿。它适用于数据分批到达、长时间运行且中间结果有意义的场景,如读取大文件、接收实时消息等。相比传统异步模式,异步流更直观地处理异步数据序列,提升响应速度与用户…

    2025年12月17日
    000
  • C#的泛型约束是什么?如何使用?

    泛型约束通过where关键字为类型参数设定条件,确保类型安全并提升代码健壮性与可读性。它支持多种约束:class(引用类型)、struct(值类型)、new()(无参构造函数)、基类或接口继承、notnull(非空)、unmanaged(非托管类型)及T:U(类型参数派生)等。这些约束可组合使用,如…

    2025年12月17日
    000
  • C#的递归函数是什么?如何使用?

    递归函数在C#中通过自我调用处理具有嵌套结构的问题,如树遍历、解析器和分治算法,其核心是基线条件和递归步;但需注意栈溢出、性能开销和调试难度等问题,在深度可控且结构匹配时优先使用递归,否则应转向迭代或结合备忘录优化。 说起C#的递归函数,其实它就是一种有点“自恋”的函数——在执行过程中,它会直接或间…

    2025年12月17日
    000
  • ASP.NET Core中的请求管道是什么?如何理解?

    ASP.NET Core请求管道是一系列按顺序执行的中间件组成的流水线,每个中间件可处理、修改或短路请求。管道在Program.cs中通过IApplicationBuilder配置,中间件顺序至关重要,直接影响请求处理流程和依赖关系。例如,UseRouting()需在UseAuthorization…

    2025年12月17日
    000

发表回复

登录后才能评论
关注微信