百度360必应搜狗淘宝本站头条
当前位置:网站首页 > IT技术 > 正文

二. Parallel.For使用(无序的),适合带索引的大量循环操作

wptr33 2025-07-21 18:18 6 浏览

有顺序

for(int i=0; i<100; i++)

Foo(i);// 并行话代码

Parallel.For(0, 100, i=> Foo(i));

// 简洁写法

Parallel.For(0, 100,Foo);

Parallel Options选项配置,有三个属性

1. Cancellation Token 取消任务,并且处理任务被取消后的一些操作

2. MaxDegreeOfParallelism 设置最大并发数,默认-1

3. TaskScheduler指定任务调度器。

ParallelLoopResult 并发结果,有两个属性

1. IsCompleted 任务是否执行完成。

2. LowestBreakIteration 调用Break方法的最小任务索引(小于这个的索引都要执行)

ParallelLoopState,由于并行的For或ForEach的循环体是一个委托,因此无法使用break语句提前结束循环。但是可以调用ParallelLoopState对象的Break方法或Stop方法来跳出或者结束循环

Break

Stop

1 /// <summary>

2 /// Parallel.For使用

3 /// </summary>

4 /// <param name="num"></param>

5 static void ParallelForFun(int num)

6 {

7 Console.WriteLine(#34;ParallelFor执行总次数:{num}");

8 var list = new List<dynamic>() ;

9 ParallelLoopResult result = Parallel.For(0, num, i =>

10 {

11 list.Add(new Product { Id = i, nameof = "Testname" });

12 Console.WriteLine(#34;Task ID:{Task.CurrentId},Thread:{Thread.CurrentThread.ManagedThreadId }");

13 Thread.Sleep(20);

14 });

15 }

a. 循环中断:Parallel.For带ParallelLoopState(执行状态,可以中途取消),带ParallelLoopResult(执行结果)

1 static void ParallelForAsyncAbort()

2 {

3

4 ParallelLoopResult result =

5 Parallel.For(10, 100, async (int index, ParallelLoopState pls) =>

6 {

7 Console.WriteLine(#34;Index:{index} task:{Task.CurrentId},Thread:{Thread.CurrentThread.ManagedThreadId }");

8 await Task.Delay(10);

9 if (index > 30)

10 pls.Break();

11 });

12 Console.WriteLine(#34;Is completed:{result.IsCompleted} LowestBreakIteration:{result.LowestBreakIteration }");

13 }

Break:不立马结束循环,而是等所有小于
ParallelLoopResult.LowestBreakIteration 的迭代执行完,才结束循环。(用Break时,记得要用大于的条件判断)

Stop:不用等,可以更快捷的结束循环。

Break与Stop都不能停止已经开始的迭代,只可以防止新的迭代开始。

b.循环取消:

1 static void ParallelForCancel()

2 {

3

4 var cts = new CancellationTokenSource();

5 cts.Token.Register(() => { Console.WriteLine(#34;*** token canceled"); });

6 cts.CancelAfter(500);//执行500毫秒后取消

7 try

8 {

9 ParallelLoopResult result = Parallel.For(0, 100, new ParallelOptions()

10 {

11 CancellationToken = cts.Token,

12 }, x =>

13 {

14 Console.WriteLine(#34;loop {x} started");

15 int sum = 0;

16 for (int i = 0; i < 100; i++)

17 {

18 Thread.Sleep(2);

19 sum += 1;

20 }

21 Console.WriteLine(#34;loop {x} finished");

22 });

23 }

24 catch (OperationCanceledException ex)

25 {

26 Console.WriteLine(ex.Message);

27 }

28 }

执行结果,可以看出,取消后,已经开始的任务,还是会继续执行完成

三:Parallel.ForEach(大数据集的循环执行,例如:数组,集合,枚举)

ParallelForEach

结果是无序的

相关推荐

oracle中merge into语句详解(oracle的merge语句)

由于工作中使用,研究了mergeinto语句是insert与update语句的结合,可以同时实现update和insert的功能。一、mergeinto语句的语法。MERGEINTOsch...

N张图告诉你K-DB为什么能全面兼容Oracle?

不是每一款数据库都能全面兼容Oracle,就像不是所有数据库都可以被称之为K-DB。一般数据库能做到的SQL标准和函数上兼容Oracle,而K-DB则能实现更多,在数据库体系架构、集群方式、数据库对象...

ORACLE 错误代码及解决办法(oracle错误码942)

ORA-00001:违反唯一约束条件(.)错误说明:当在唯一索引所对应的列上键入重复值时,会触发此异常。ORA-00017:请求会话以设置跟踪事件ORA-00018:超出最大会话数ORA-00...

SQL知识大全三):SQL中的字符串处理和条件查询

点击上方蓝字关注我们今天是SQL系列的第三讲,我们会讲解条件查询,文本处理,百分比,行数限制,格式化以及子查询。...

LabVIEW实现Oracle数据库的访问(深入浅出labview数据库应用)

1.安装Oracle客户端下载:从Oracle官方网站下载适用于Windows操作系统的Oracle驱动程序。确保下载的版本与LabVIEW环境和操作系统兼容。...

Oracle查询语句,你知道几个?(oracle常用查询语句)

介绍以下非常有用的Oracle查询语句,主要涵盖了日期操作,获取服务器信息,获取执行状态,计算数据库大小等方面的查询。日期/时间查询1、获取当前月份的第一天运行这个命令能快速返回当前月份的第一天,可...

Oracle数据库中判断字段不为空?(oracle数据库中判断字段不为空的函数)

Oracle数据库中如何判断字段不为空在Oracle数据库中,判断字段(列)不为空通常涉及到几种不同的场景和需求。下面是一些常见的方法来检查字段是否不为空:1.使用NVL函数NVL函数可以用来将NU...

Oracle 字典表使用函数自动转码,自定义函数传参

创建函数模板CREATEORREPLACEFUNCTIONdic_val--定义函数(dict_idINVARCHAR2,codeINVARCHAR2)--定义参数RETURN...

从上百个字段到1个CLOB:Oracle JSON存储实战指南

陆沉盯着左右两个屏幕上显示的数据格式文档,右手小拇指无意思地一下又一下的敲击着机械键盘的Ctrl键,在清脆的“哒哒”声中思考着。...

程序员面试中问到的Oracle常用数据类型

Oracle中常用数据类型有:1、字符类型1.1、定长字符1.1.1、Char字符长度不够自动在右边加空格符号。最大存2000个字符,当字符长度超出2000个报错。不指定大小默认为1。1.1.2、...

了解 Oracle 中单引号与双引号的用法,一篇文章教会你!

无论测试或者开发,对数据库的增删改查都是家常便饭。但有些小知识是经常被忽略,却又不能不去了解的,例如单引号和双引号的用法和区别,看完这一篇,你肯定会有收获。...

Oracle字符串转日期错误,试试TO_TIMESTAMP函数

最近,在工作中,发现有些字符串格式无法转换成日期格式,如下图:这种to_date是无法转换的,会报错,因此,需要用到:TO_TIMESTAMP,具体格式如下:TO_TIMESTAMP(字段名,...

oracle——空字符串(&#39;&#39;)不能用和!=

oracle——空字符串('')不能用<>和!=最近在查询空字符串的数据时发现查询不出数据。后来发现以前的写法在oracle中不能用。记录一下:数据如下:...

oracle的listagg函数,可以把多行转为一个字符串

oracle的listagg函数可以把多行转为一个字符串,用起来很方便,示例如下:witht1as(select'001'asitemcode,'苹果'...

MySQL 教程的天花板--入门到高级(mysql实用教程)

给大家推荐一套MySQL的教程,堪称MySQL教程的天花板。此教程包含...