C#多线程之Parallel类的用法
作者:Ruby_Lu 发布时间:2023-05-15 06:02:03
Parallel类是对线程的一个抽象。该类位于System.Threading.Tasks名称空间中,提供了数据和任务并行性。
Paraller类定义了数据并行地For和ForEach的静态方法,以及任务并行的Invoke的静态方法。Parallel.For()和Parallel.ForEach()方法在每次迭代中调用相同的代码,Paraller.Invoke()允许调用不同的方法。
1.Parallel.For
Parallel.For()方法类似C#语法的for循环语句,多次执行一个任务。但该方法并行运行迭代,迭代的顺序没有定义。
Parallel.For()方法中,前两个参数定义了循环的开头和结束,第三个参数是一个Action委托。Parallel.For方法返回类型是ParallelLoopResult结构,它提供了循环是否结束的信息。
Parallel.For有多个重载版本和多个泛型重载版本。
示例:
static void ForTest()
{
ParallelLoopResult plr =
Parallel.For(0,10,i => {
Console.WriteLine("{0},task:{1},thread:{2}",i,Task.CurrentId,Thread.CurrentThread.ManagedThreadId);
Thread.Sleep(5000);
});
if (plr.IsCompleted)
Console.WriteLine("completed!");
}
输出:
任务不一定映射到一个线程上。线程也可以被不同的任务重用。
上面的例子,使用了.NET 4.5中新增的Thread.Sleep方法,而不是Task.Delay方法。Task.Delay是一个异步(http://www.cnblogs.com/afei-24/p/6757361.html)方法,用于释放线程供其它任务使用。
示例:
static void ForTestDelay()
{
ParallelLoopResult plr =
Parallel.For(0, 10,async i => {
Console.WriteLine("{0},task:{1},thread:{2}", i, Task.CurrentId, Thread.CurrentThread.ManagedThreadId);
await Task.Delay(1000);
Console.WriteLine("{0},task:{1},thread:{2}", i, Task.CurrentId, Thread.CurrentThread.ManagedThreadId);
});
if (plr.IsCompleted)
Console.WriteLine("completed!");
Console.ReadKey();
}
输出:
上面代码使用了await关键字进行延迟,输出结果显示延迟前后的代码运行在不同的线程中。而且延迟后的任务不再存在,只留下线程,这里还重用了前面的线程。另一个重要的方面是,Parallel类的For方法并没有等待延迟,而是直接完成。parallel类只等待它创建的任务,而不等待其它后台活动。所以上面代码使用了Console.ReadKey();使主线程一直运行,不然很可能看不到后面的输出。
2.提前停止Parallel.For
For()方法的一个重载版本接受第三个Action<int,ParallelLoopState>委托类型的参数。使用这个方法可以调用ParallelLoopState的Break()或Stop()方法,以停止循环。
注意,前面说到,迭代的顺序是没有定义的。
示例:
static void ForStop()
{
ParallelLoopResult plr =
Parallel.For(0,10,(int i,ParallelLoopState pls)=> {
Console.WriteLine("{0},task:{1},thread:{2}", i, Task.CurrentId, Thread.CurrentThread.ManagedThreadId);
if (i > 5)
pls.Break();
});
Console.WriteLine("is completed:{0}",plr.IsCompleted);
Console.WriteLine("最低停止索引:{0}",plr.LowestBreakIteration);
}
输出:
迭代值在大于5时中断,但其它已开始的任务同时执行。
3.对Parallel.For中的每个线程初始化
Parallel.For方法使用多个线程来执行循环,如果需要对每个线程进行初始化,就可以使用Parallel.For<TLocal>()方法。除了from和to对应的值之外,Parallel.For方法的泛型版本还接受3个委托参数:
第一个委托参数的类型是Func<TLocal>,这个方法仅对用于执行迭代的每个线程调用每一次。
第二个委托参数为循环体定义了委托。该参数类型是Func<int, ParallelLoopState, TLocal, TLocal>。其中第一个参数是循环迭代,第二个参数ParallelLoopState允许停止循环,第三个参数接受从上面参数委托Func<TLocal>返回的值,该委托还需返回一个TLocal类型的值。该方法对每次迭代调用。
第三个委托参数指定一个委托Action<TLocal>,接受第二个委托参数的返回值。这个方法仅对用于执行迭代的每个线程调用每一次。
示例:
static void ForInit()
{
ParallelLoopResult plr =
Parallel.For(0,10,()=> {
Console.WriteLine("init thread:{0},task:{1}",Thread.CurrentThread.ManagedThreadId,Task.CurrentId);
return Thread.CurrentThread.ManagedThreadId.ToString();
},
(i, pls,strInit)=> {
Console.WriteLine("body:{0},strInit:{1},thraed:{2},task:{3}",i,strInit,Thread.CurrentThread.ManagedThreadId,Task.CurrentId);
return i.ToString();
},
(strI)=> {
Console.WriteLine("finally {0}",strI);
});
}
输出:
4.Parallel.ForEach
Parallel.ForEach方法遍历实现了IEnumerable的集合,类似于foreach,但以异步方式遍历。没有确定遍历顺序。
示例:
static void ForeachTest()
{
string[] data = { "zero", "one", "two", "three", "four", "five", "six", "seven", "eight", "nine", "ten", "eleven", "twelve" };
ParallelLoopResult plr = Parallel.ForEach<string>(data, s =>
{
Console.WriteLine(s);
});
if (plr.IsCompleted)
Console.WriteLine("completed!");
}
如果需要中断,可以使用ForEach的重载版本和参数ParallelLoopState。
访问索引器:
ParallelLoopResult plr1 = Parallel.ForEach<string>(data, (s,pls,l) =>
{
Console.WriteLine("data:{0},index:{1}",s,l);
});
5.Parallel.Invoke
如果多个任务并行运行,可以使用Parallel.Invoke方法。该方法允许传递一个Action委托数组。
static void ParallerInvoke()
{
Action[] funs = { Fun1,Fun2};
Parallel.Invoke(funs);
}
static void Fun1()
{
Console.WriteLine("f1");
Console.WriteLine("task:{0},thread:{1}", Task.CurrentId, Thread.CurrentThread.ManagedThreadId);
}
static void Fun2()
{
Console.WriteLine("f2");
Console.WriteLine("task:{0},thread:{1}", Task.CurrentId, Thread.CurrentThread.ManagedThreadId);
}
来源:https://www.cnblogs.com/afei-24/p/6904179.html
猜你喜欢
- 本文实例总结了C#生成随机数的方法。分享给大家供大家参考。具体分析如下:开始,很简单地使用System.Random类来生成随机数。很快,问
- 一、JPA介绍JPA是Java Persistence API的简称,中文名Java持久层API,是JDK 5.0注解或XML描述对象-关系
- 简介redis 多数据源主要的运用场景是在需要使用多个redis服务器或者使用多个redis库,本文采用的是fastdep依赖集成框架,快速
- 前言古语有云:道为术之灵,术为道之体;以道统术,以术得道。其中:“道”指“规律、道理、理论”,“术”指“方法、技巧、技术”。意思是:“道”是
- 在正式的进入主题之前,我们先来了解下深拷贝和前拷贝的概念:浅拷贝:会创建一个新对象,这个对象有着原始对象属性值的一份精确拷贝,如果属性是基本
- 本文实例总结了Android实现屏幕旋转方法。分享给大家供大家参考。具体如下:在介绍之前,我们需要先了解默认情况下android屏幕旋转的机
- 假设下面是你的视频网站链接列表,如果别人想爬取你的数据十分轻松,看规则就知道数据库是序列自增的http://www.xxxx.com/vid
- 图片的复制无非有两种方法,一种是图片直接上传到服务器,另外一种转换成二进制流的base64码目前限chrome浏览器使用首先以um-edit
- 场景重现:1.微信小程序向后台发送请求 ——而后台web采用的springSecuriry没有token生成,就会拦截请求,,所以小编记录下
- Java公众号【Java技术迷】一个在互联网领先地位,微信搜索【Java技术迷】第一时间阅读最新文章,通过下面下载链接,即可获得我精心整理的
- 读取本地的xml文件,通过DOM进行解析,DOM解析的特点就是把整个xml文件装载入内存中,形成一颗DOM树形结构,树结构是方便遍历和和操纵
- SpringBoot配置文件中设置server.port不生效我的配置文件为:# application.ymlserver:
- 日常的Rest服务开发我都会首选SpringBoot,因为它本身的易用性以及自带的各种方便功能、生态等,今天就简单讲一下如何将Spring
- 关于SQLiteSQLite是一款轻型的嵌入式的遵守ACID的关系型数据库管理系统,诞生已有15个年头了。随着移动互联的发展,现在得到了更广
- 接口:官方的含义是---->java接口是一系列方法的声明,是一些方法特征的集合疑问:那为什么不用抽象类呢?把他们共有的方法集合起来放
- 起源flutter作为一个跨平台的框架,在绘制上体现出了它跨平台的良好性能.那么,它是如何从runApp()后 绘制上屏的呢?本文将与你一起
- Warning:这是《Java 程序员进阶之路》专栏的第 55 篇。回来后小二找到了我,于是我就写下了这篇文章丢给他,并严厉地告诉他:再搞不
- 做项目时使用maven构建项目已经是现在的流行做法了。那么maven的作用是什么呢?maven中的几个常用的命令都有什么用?下面我们来看一下
- 在使用NavigationPage导航的时候, 我们可以给里面添加一些功能按钮, 如下所示:<ContentPage.ToolbarI
- 应用场景:当交易发生之后一段时间内,由于买家或者卖家的原因需要退款时,卖家可以通过退款接口将支付款退给买家,微信支付将在收到退款请求并且验证