二. 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——空字符串('')不能用和!=
-
oracle——空字符串('')不能用<>和!=最近在查询空字符串的数据时发现查询不出数据。后来发现以前的写法在oracle中不能用。记录一下:数据如下:...
- oracle的listagg函数,可以把多行转为一个字符串
-
oracle的listagg函数可以把多行转为一个字符串,用起来很方便,示例如下:witht1as(select'001'asitemcode,'苹果'...
- MySQL 教程的天花板--入门到高级(mysql实用教程)
-
给大家推荐一套MySQL的教程,堪称MySQL教程的天花板。此教程包含...
- 一周热门
-
-
因果推断Matching方式实现代码 因果推断模型
-
C# 13 和 .NET 9 全知道 :13 使用 ASP.NET Core 构建网站 (1)
-
git pull命令使用实例 git pull--rebase
-
git 执行pull错误如何撤销 git pull fail
-
面试官:git pull是哪两个指令的组合?
-
git pull 和git fetch 命令分别有什么作用?二者有什么区别?
-
git fetch 和git pull 的异同 git中fetch和pull的区别
-
git pull 之后本地代码被覆盖 解决方案
-
还可以这样玩?Git基本原理及各种骚操作,涨知识了
-
git命令之pull git.pull
-
- 最近发表
-
- oracle中merge into语句详解(oracle的merge语句)
- N张图告诉你K-DB为什么能全面兼容Oracle?
- ORACLE 错误代码及解决办法(oracle错误码942)
- SQL知识大全三):SQL中的字符串处理和条件查询
- LabVIEW实现Oracle数据库的访问(深入浅出labview数据库应用)
- Oracle查询语句,你知道几个?(oracle常用查询语句)
- Oracle数据库中判断字段不为空?(oracle数据库中判断字段不为空的函数)
- Oracle 字典表使用函数自动转码,自定义函数传参
- 从上百个字段到1个CLOB:Oracle JSON存储实战指南
- 程序员面试中问到的Oracle常用数据类型
- 标签列表
-
- git pull (33)
- git fetch (35)
- mysql insert (35)
- mysql distinct (37)
- concat_ws (36)
- java continue (36)
- jenkins官网 (37)
- mysql 子查询 (37)
- python元组 (33)
- mybatis 分页 (35)
- vba split (37)
- redis watch (34)
- python list sort (37)
- nvarchar2 (34)
- mysql not null (36)
- hmset (35)
- python telnet (35)
- python readlines() 方法 (36)
- munmap (35)
- docker network create (35)
- redis 集合 (37)
- python sftp (37)
- setpriority (34)
- c语言 switch (34)
- git commit (34)