0

0

c# 如何在 C# 中实现一个可取消的 Parallel.For

畫卷琴夢

畫卷琴夢

发布时间:2026-03-11 11:04:03

|

495人浏览过

|

来源于php中文网

原创

parallel.for支持合作式取消,需通过paralleloptions传入cancellationtoken,检查在每次迭代前进行,正在执行的迭代不会中断,必须捕获operationcanceledexception。

c# 如何在 c# 中实现一个可取消的 parallel.for

Parallel.For 本身支持取消,但必须传入 CancellationToken

默认的 Parallel.For(int, int, Action<int>)</int> 重载不接受取消令牌,所以直接调用无法中途退出。真正支持取消的是带 ParallelOptions 的重载——你得显式构造并传入 CancellationToken

常见错误是只创建了 CancellationTokenSource 却没把它塞进 ParallelOptions,结果调用 Cancel() 完全没反应。

  • Parallel.For 检测取消是“合作式”的:它只在每次迭代开始前检查令牌是否已取消,不会中断正在执行的迭代体
  • 如果某次循环体耗时很长(比如 IO 或计算密集),该次迭代仍会跑完,之后才退出整个循环
  • 必须捕获 OperationCanceledException,否则异常会向上抛出并终止整个程序(除非你用 try/catch 包裹 Parallel.For 调用)

正确写法:用 ParallelOptions + CancellationToken

下面是最小可运行示例,演示如何触发取消并安全退出:

var cts = new CancellationTokenSource();

var options = new ParallelOptions
{
    CancellationToken = cts.Token,
    MaxDegreeOfParallelism = Environment.ProcessorCount
};

try
{
    Parallel.For(0, 1000, options, i =>
    {
        // 模拟工作:每 100 次迭代检查一次是否该退出(避免太频繁检查)
        if (i % 100 == 0) options.CancellationToken.ThrowIfCancellationRequested();

        Thread.Sleep(10); // 模拟耗时操作
        Console.WriteLine($"Working on {i}");
    });
}
catch (OperationCanceledException)
{
    Console.WriteLine("Parallel.For was cancelled.");
}
finally
{
    cts.Dispose();
}

注意:ThrowIfCancellationRequested() 是推荐做法,比手动检查 IsCancellationRequested 更安全(它还会校验 IsDisposed 等状态)。

Moshi Chat
Moshi Chat

法国AI实验室Kyutai推出的端到端实时多模态AI语音模型,具备听、说、看的能力,不仅可以实时收听,还能进行自然对话。

下载

取消后如何知道哪些项已完成、哪些被跳过?

Parallel.For 不提供“已处理索引列表”这类返回值。如果你需要精确追踪进度或恢复断点,它不是合适工具——考虑改用 Partition + Task.Run + await Task.WhenAny 手动编排,或者用 PLINQAsParallel().WithCancellation() 配合 ToList()ForAll()

  • Parallel.For 的设计目标是吞吐优先,不是状态可控
  • 取消发生后,ParallelLoopState.LowestBreakIterationBreak() 场景下才有意义;对 CancellationToken 无效
  • 不要依赖循环变量 i 的最终值来判断范围——它可能停留在任意位置,且无定义

替代方案:为什么有时该放弃 Parallel.For

当你需要以下任一能力时,Parallel.For 就显得力不从心:

  • 逐个 await 异步操作(Parallel.For 不支持 async/await
  • 动态调整任务粒度(比如按数据块分发,而非固定索引)
  • 取消后获取剩余未处理项列表
  • 细粒度错误分类(如区分取消、超时、业务异常)

这时候更稳妥的做法是用 Task.Run 启动一组 Task,用 Task.WhenAny 监听完成或取消,并自行维护状态。虽然代码多几行,但控制权完全在你手里。

真正容易被忽略的一点:即使你传了 CancellationToken,只要循环体内部有阻塞调用(比如没加 awaitHttpClient.SendAsync),取消信号也会被卡住——因为线程被占着,Parallel.For 没机会检查令牌。这种场景必须用异步替代同步,或把耗时操作移到单独线程并配合 cts.Token.Register 主动响应。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
登录token无效
登录token无效

登录token无效解决方法:1、检查token的有效期限,如果token已经过期,需要重新获取一个新的token;2、检查token的签名,如果签名不正确,需要重新获取一个新的token;3、检查密钥的正确性,如果密钥不正确,需要重新获取一个新的token;4、使用HTTPS协议传输token,建议使用HTTPS协议进行传输 ;5、使用双因素认证,双因素认证可以提高账户的安全性。

6605

2023.09.14

登录token无效怎么办
登录token无效怎么办

登录token无效的解决办法有检查Token是否过期、检查Token是否正确、检查Token是否被篡改、检查Token是否与用户匹配、清除缓存或Cookie、检查网络连接和服务器状态、重新登录或请求新的Token、联系技术支持或开发人员等。本专题为大家提供token相关的文章、下载、课程内容,供大家免费下载体验。

842

2023.09.14

token怎么获取
token怎么获取

获取token值的方法:1、小程序调用“wx.login()”获取 临时登录凭证code,并回传到开发者服务器;2、开发者服务器以code换取,用户唯一标识openid和会话密钥“session_key”。想了解更详细的内容,可以阅读本专题下面的文章。

1092

2023.12.21

token什么意思
token什么意思

token是一种用于表示用户权限、记录交易信息、支付虚拟货币的数字货币。可以用来在特定的网络上进行交易,用来购买或出售特定的虚拟货币,也可以用来支付特定的服务费用。想了解更多token什么意思的相关内容可以访问本专题下面的文章。

2103

2024.03.01

java中break的作用
java中break的作用

本专题整合了java中break的用法教程,阅读专题下面的文章了解更多详细内容。

120

2025.10.15

java break和continue
java break和continue

本专题整合了java break和continue的区别相关内容,阅读专题下面的文章了解更多详细内容。

261

2025.10.24

string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

1010

2023.08.02

int占多少字节
int占多少字节

int占4个字节,意味着一个int变量可以存储范围在-2,147,483,648到2,147,483,647之间的整数值,在某些情况下也可能是2个字节或8个字节,int是一种常用的数据类型,用于表示整数,需要根据具体情况选择合适的数据类型,以确保程序的正确性和性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

608

2024.08.29

C# ASP.NET Core微服务架构与API网关实践
C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开,系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

3

2026.03.11

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
C# 教程
C# 教程

共94课时 | 11.1万人学习

C 教程
C 教程

共75课时 | 5.3万人学习

C++教程
C++教程

共115课时 | 21.4万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号