0

0

C#怎么使用Parallel.ForEach C#并行循环加速处理

幻夢星雲

幻夢星雲

发布时间:2026-01-14 19:07:16

|

700人浏览过

|

来源于php中文网

原创

parallel.foreach可自动并行化cpu密集型任务,但需确保线程安全、避免共享状态、慎用于i/o场景;基本用法是替换foreach并使用system.threading.tasks;推荐用局部状态+合并方式处理聚合结果,配合paralleloptions控制并发度,异常需捕获aggregateexception并遍历innerexceptions。

c#怎么使用parallel.foreach c#并行循环加速处理

Parallel.ForEach 能让集合遍历自动并行化,显著提升 CPU 密集型任务的执行速度,但不是所有场景都适合——关键看是否线程安全、有无共享状态、是否 I/O 主导。

基本用法:替换普通 foreach

把原来的串行循环改成并行,只需两步:

  • 引用 System.Threading.Tasks
  • Parallel.ForEach(集合, item => { /* 处理逻辑 */ }) 替代 foreach

例如处理一个整数列表求平方:

(注意:下面代码不涉及共享变量,是安全的)

var numbers = Enumerable.Range(1, 100000).ToList();
Parallel.ForEach(numbers, n => {
    var result = n * n; // 纯计算,无副作用
    // 可以写入线程本地变量或加锁写入共享结构
});

避免共享资源冲突:别直接改公共变量

多个线程同时写同一个变量(如 sum += n)会导致结果错误。正确做法有:

  • Interlocked.Add(ref sum, n) 原子操作(适合简单数值累加)
  • lock(obj) 包裹临界区(开销略大,但通用)
  • Parallel.ForEach 的重载 + 局部状态(推荐,性能最好)

局部状态示例(每个线程独立累加,最后合并):

玄鲸Timeline
玄鲸Timeline

一个AI驱动的历史时间线生成平台

下载
(适用于需要汇总结果的场景)

int total = Parallel.ForEach(
    numbers,
    () => 0, // 每个线程的局部初始值
    (n, loopState, localSum) => localSum + n * n, // 局部处理
    localSum => Interlocked.Add(ref total, localSum) // 合并到全局
);

控制并发度:防止线程过多拖慢性能

默认会根据 CPU 核心数动态调整线程数,但遇到大量小任务或内存敏感场景,可手动限制:

  • 传入 new ParallelOptions { MaxDegreeOfParallelism = 4 }
  • 一般设为 Environment.ProcessorCount 或略高,避免上下文切换开销
  • 特别耗内存的任务(如图像处理),适当调低更稳

提前退出和异常处理

不能用 breakreturn 直接跳出整个循环,但可以:

  • 调用 loopState.Break():通知后续分区尽快停止(已开始的仍会完成)
  • 调用 loopState.Stop():尽量立即中止所有未开始的迭代
  • 异常会被包装成 AggregateException,需 try-catch 并遍历 .InnerExceptions

例如查找第一个满足条件的元素:

int? found = null;
Parallel.ForEach(numbers, (n, loopState) => {
    if (n > 50000) {
        found = n;
        loopState.Stop(); // 不再启动新任务
    }
});

基本上就这些。用对了能快几倍,用错了反而更慢或出错——核心就三条:无共享写、合理控并发、异常要拆包。

热门AI工具

更多
DeepSeek
DeepSeek

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

豆包大模型
豆包大模型

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

通义千问
通义千问

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

腾讯元宝
腾讯元宝

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

文心一言
文心一言

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

讯飞写作
讯飞写作

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

即梦AI
即梦AI

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

ChatGPT
ChatGPT

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

相关专题

更多
php中foreach用法
php中foreach用法

本专题整合了php中foreach用法的相关介绍,阅读专题下面的文章了解更多详细教程。

202

2025.12.04

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

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

120

2025.10.15

java break和continue
java break和continue

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

261

2025.10.24

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

723

2023.08.10

Golang 测试体系与代码质量保障:工程级可靠性建设
Golang 测试体系与代码质量保障:工程级可靠性建设

Go语言测试体系与代码质量保障聚焦于构建工程级可靠性系统。本专题深入解析Go的测试工具链(如go test)、单元测试、集成测试及端到端测试实践,结合代码覆盖率分析、静态代码扫描(如go vet)和动态分析工具,建立全链路质量监控机制。通过自动化测试框架、持续集成(CI)流水线配置及代码审查规范,实现测试用例管理、缺陷追踪与质量门禁控制,确保代码健壮性与可维护性,为高可靠性工程系统提供质量保障。

22

2026.02.28

Golang 工程化架构设计:可维护与可演进系统构建
Golang 工程化架构设计:可维护与可演进系统构建

Go语言工程化架构设计专注于构建高可维护性、可演进的企业级系统。本专题深入探讨Go项目的目录结构设计、模块划分、依赖管理等核心架构原则,涵盖微服务架构、领域驱动设计(DDD)在Go中的实践应用。通过实战案例解析接口抽象、错误处理、配置管理、日志监控等关键工程化技术,帮助开发者掌握构建稳定、可扩展Go应用的最佳实践方法。

15

2026.02.28

Golang 性能分析与运行时机制:构建高性能程序
Golang 性能分析与运行时机制:构建高性能程序

Go语言以其高效的并发模型和优异的性能表现广泛应用于高并发、高性能场景。其运行时机制包括 Goroutine 调度、内存管理、垃圾回收等方面,深入理解这些机制有助于编写更高效稳定的程序。本专题将系统讲解 Golang 的性能分析工具使用、常见性能瓶颈定位及优化策略,并结合实际案例剖析 Go 程序的运行时行为,帮助开发者掌握构建高性能应用的关键技能。

23

2026.02.28

Golang 并发编程模型与工程实践:从语言特性到系统性能
Golang 并发编程模型与工程实践:从语言特性到系统性能

本专题系统讲解 Golang 并发编程模型,从语言级特性出发,深入理解 goroutine、channel 与调度机制。结合工程实践,分析并发设计模式、性能瓶颈与资源控制策略,帮助将并发能力有效转化为稳定、可扩展的系统性能优势。

16

2026.02.27

Golang 高级特性与最佳实践:提升代码艺术
Golang 高级特性与最佳实践:提升代码艺术

本专题深入剖析 Golang 的高级特性与工程级最佳实践,涵盖并发模型、内存管理、接口设计与错误处理策略。通过真实场景与代码对比,引导从“可运行”走向“高质量”,帮助构建高性能、可扩展、易维护的优雅 Go 代码体系。

17

2026.02.27

热门下载

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

精品课程

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

共94课时 | 10.5万人学习

C 教程
C 教程

共75课时 | 5.1万人学习

C++教程
C++教程

共115课时 | 20.1万人学习

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

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