当前位置：网站首页 > 热门文章 > 正文

C#并行编程:Parallel类（c# 并行处理）

bigegpt 2025-06-13 11:29 8 浏览

在Parallel类中提供了三个静态方法作为结构化并行的基本形式：

Parallel.Invoke方法：并行执行一组委托。

Parallel.For方法：执行与C# for循环等价的并行方法。

Parallel.ForEach方法：执行与C#foreach循环等价的并行方法。

这三个方法都会阻塞线程直到所有工作完成为止。和PLINQ一样，在出现未处理异常之后，其他的工作线程将会在其当前迭代完成之后停止，并将异常包装为AggregateException抛出给调用者。

1. 与PLINQ一样，Parallel.*方法是针对计算密集型任务而不是I/O密集型任务进行优化的。

2. 循环是无序的，如果需要顺序，直接使用同步。

3. 如果用到共享变量，要使用线程同步锁。

4. 如果虽是大量，但简单无等待的操作，同步执行可能更快。

5. 如果是带数据库操作，请使用事务，注意错误处理。

6. ForEach 比For效率更高。

一： Parallel.Invoke：并行执行一组Action委托，然后等待它们完成（尽可能的同时执行）。

1. 该方法最简单的定义方式如下：public static void Invoke (params Action[] actions);

2. 如果任务不超过10个，建议直接用Task，因为不超过10个的时候，Invoke内部会使用Task.Factory.StartNew创建任务。直接用Task.Factory.StartNew或者Task.Run效率更高。

3. 适合用于执行大量且无返回值的场景：如果将一百万个委托传递给Parallel.Invoke方法，它仍然能够有效工作。这是因为该方法会将大量的元素划分为若干批次（自动分批处理），并将其分派给底层的Task。

1 #region 第一种模式

2 static void ParallelInvoke1()

3 {

4 Parallel.Invoke(Fun1, Fun2);

5 }

6 static void Fun1()

7 {

8 Console.WriteLine("Fun1");

9 }

10 static void Fun2()

11 {

12 Console.WriteLine("Fun2");

13 }

14 #endregion

15 #region 第二种模式

16 static void ParallelInvoke2()

17 {

18 Action action = () =>

19 {

20 Console.WriteLine(#34;Thread Id:{Thread.CurrentThread.ManagedThreadId }");

21 };

22 Parallel.Invoke(action, action, action, action, action, action, action, action, action, action, action, action);

23 Console.WriteLine("Parallel.Invoke 执行完成");

24 }

25 #endregion

c#for

上一篇：颠覆认知!用Span重构foreach循环竟让数据处理快如闪电
下一篇：C#中$的用法?（c#中&&什么意思）

C#并行编程:Parallel类（c# 并行处理）

相关推荐

idea本地配置连接远程hadoop集群的一些网络问题解决汇总

无缓存不行?例行升级的入门级阿斯加特AN2 SSD装机点评

Ceph运维手册(基于P版本)

大数据开发前要做什么准备?8台Hadoop服务器进行集群规划前配置

Tensorflow分类loss函数总结 tensorflow绘制loss曲线

R语言学习笔记(七) -离散型数据的模型预测2

iOS Runtime详解

7 个对 Java 意义重大的性能指标，你知道几个?

PHP 远程调试最佳实践

Laravel框架使用图片处理简单教程