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

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

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

有顺序

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

结果是无序的

相关推荐

Python钩子函数实现事件驱动系统(flask钩子)

钩子函数(HookFunction)是现代软件开发中一个重要的设计模式,它允许开发者在特定事件发生时自动执行预定义的代码。在Python生态系统中,钩子函数广泛应用于框架开发、插件系统、事件处理和中...

Python 项目中使用锁的棘手问题及深度解决方法

在Python多线程开发中,锁的使用看似简单,实则暗藏诸多棘手问题。这些问题往往在高并发场景下才会暴露,且排查难度大、影响范围广。本文将针对实际项目中锁使用的棘手场景,从问题根源出发,提供系统性的...

学Python基础这么久了,花了好长时间精心记录的学习笔记

我为什么要学Python呢!当我刚开始接触Python时,我就感觉Python是一种很高级的语言。我很喜欢,对,就是因为喜欢。好了!话不多说,开始看笔记了,喜欢的朋友可以点赞关注转发哦~...

Python浅拷贝深拷贝之copy、deepcopy

笔记记录20221205:个人总结:1,两者基本区别不大;2,在涉及到子对象时候,两者才有区别;3,在涉及到子对象,且子对象的操作后内存地址没有发生变化(如下方代码:dic1['one'...

自学python第四天:列表(python入门之玩转列表)

列表在Python中,用方括号([])表示列表,用逗号分隔其中的元素。例:cars=['搅拌车','运钞车','大货车']print(car...

先Mark后用!8分钟读懂 Python 性能优化

从本文总结了Python开发时,遇到的性能优化问题的定位和解决。概述:性能优化的原则——优化需要优化的部分。性能优化的一般步骤:首先,让你的程序跑起来结果一切正常。然后,运行这个结果正常的代码,看看它...

Python基础编程——字典的常用方法(三)

前一节介绍了get()、items()、keys()、pop()四种字典的常用方法,本节继续介绍剩余的四种字典常用的方法:popitem()、setdefault()、update()、values(...

Python 获取图片内容的方法(python获取图片并储存图片)

在网络爬虫和数据处理中,获取图片内容是常见需求。Python通过相关库可以便捷地从网络或本地获取图片内容,以下是具体实现方法及注意事项。一、从网络获取图片内容1.1使用requests库获取r...

一天快速入门 Python(python入门很简单)

Python是由GuidoVanRossum在90年代早期设计,现在是最常用的编程语言之一。特别是人工智能的火热,再加之它的语法简洁且优美,实乃初学者入门AI必备的编程语言。作者|yuq...

Python集合17个方法详解(python集合的概念)

01、add()描述:add()方法用于给集合添加元素,如果添加的元素在集合中已存在,则不执行任何操作。注意:集合中只能包含可哈希的对象,即list,dict都不能嵌入到集合语法:set.add...

Python字典:定义、基本操作与方法详解

什么是字典在Python中,字典(dict)是一种无序的、可变的数据类型,用于存储键-值(key-value)对。字典中的键必须是唯一的,且不可变的数据类型(如字符串、数字、元组),而值可以是任何数据...

Python小案例47-集合的操作和方法

Python中的集合是一种无序且不重复的数据结构。它们是可变的,可以添加、删除和修改元素。下面是一些常用的集合操作和方法:...

Python 项目中使用锁的常见问题及解决方法

在Python多线程编程中,锁是保证共享资源安全访问的核心机制。然而,锁的不当使用往往会引发新的问题,如死锁、性能损耗等。本文结合实际项目场景,深入剖析锁在使用过程中的常见问题,并提供可落地的解决...

python中元组,列表,字典,集合删除项目方式的归纳

九三,君子终日乾乾,夕惕若,厉无咎。在使用python过程中会经常遇到这...

python学习教程-第五节内容(python系列教程)

字符串大小写转换方法查找和替换方法判断字符串内容类型字符串开头结尾判断字符串分割和连接...