C#并行库Parallel类介绍
Parallel.Invoke
这个函数的功能和Task有些相似，就是并发执行一系列任务，然后等待所有完成。和Task比起来，省略了Task.WaitAll这一步，自然也缺少了Task的相关管理功能。它有两种形式:
Parallel.Invoke( params Action[] actions); Parallel.Invoke(Action[] actions,TaskManager manager,TaskCreationOptions options);
第二种方式可以自定义一个TaskManager对任务的执行线程进行管理（第一种方式用的是默认的TaskManager.Default）。
示例如下：
static void Main(string[] args)
{
var actions = new Action[]{
() => ActionTest("test 1"),
() => ActionTest("test 2"),
() => ActionTest("test 3"),
() => ActionTest("test 4")};
Console.WriteLine("Parallel.Invoke 1 Test");
Parallel.Invoke(actions);
Console.WriteLine();
Console.WriteLine("Parallel.Invoke 2 Test");
Parallel.Invoke(actions, new TaskManager(new TaskManagerPolicy(1, 1, 2)), TaskCreationOptions.None);
}
static void ActionTest(object value)
{
Console.WriteLine(">>> thread:{0}, value:{1}",
Thread.CurrentThread.ManagedThreadId, value);
}输出结果如下：
Parallel.Invoke 1 Test
>>> thread:3, value:test 1
>>> thread:3, value:test 2
>>> thread:4, value:test 3
>>> thread:5, value:test 4
Parallel.Invoke 2 Test
>>> thread:7, value:test 1
>>> thread:7, value:test 2
>>> thread:8, value:test 3
>>> thread:7, value:test 4
可见，由于第二次指定了最多只能使用两个线程来执行，故只有两个Task并发执行。
Parallel.ForEach和Parallel.For
Parallel.ForEach和Parallel.For用得要更加广泛一些，他可以根据一个数据源来生成一些任务（Parallel.Invoke需要事先生成这些任务），同时并发执行这些任务。基本示例如下：
static void Main(string[] args)
{
var data = new object[] { "test 1", "test 2", "test 3" };
Console.WriteLine("Parallel.ForEach Test");
Parallel.ForEach(data, item => ActionTest(item));
Console.WriteLine();
Console.WriteLine("Parallel.For Test");
Parallel.For(0, data.Length, index => ActionTest(data[index]));
}这两个函数都有多种重载形式，提供了许多控制功能，由于用得不是很多，这里就不一一介绍了。但有一点不是很好：如果需要用TaskManager的话，不得不用那最复杂的那一种形式。希望最终版本的时候会提供更合理的重载形式，毕竟TaskManager还是很常用的（虽然目前的TaskManager功能薄弱了点），而那些复杂的参数不是很常用的。因此，这里提供了两个常用的扩展方法的封装：
public static class ParallelExtend
{
public static void ParallelForEach<T>(this IEnumerable<T> source, Action<T> hanlder)
{
Parallel.ForEach(source, hanlder);
}
public static void ParallelForEach<T>(this IEnumerable<T> source, Action<T> hanlder, TaskManagerPolicy policy)
{
using (var manager = new TaskManager(policy))
{
Parallel.ForEach(source,
() => 0,
(item, index, state) => hanlder(item),
local => { },
manager,
TaskCreationOptions.None);
}
}
}通过扩展方法的方式用起来还是比较方便的。
到此这篇关于C#并行库Parallel类的文章就介绍到这了。希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
这篇文章主要为大家介绍了算法证明每一位都相同十进制数不是完全平方数的过程论述，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-05-05
C#利用System.Threading.Thread.Sleep即时输出信息的详解
本篇文章是对C#利用System.Threading.Thread.Sleep即时输出信息进行了详细的分析介绍，需要的朋友参考下2013-06-06
本篇文章主要介绍了C# DateTime与时间戳转换实例，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-06-06![浅谈C#中[]的几种用法](//img.jbzj.com/images/xgimg/bcimg3.png)
本文主要介绍了浅谈C#中[]的几种用法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-01-01
这篇文章主要介绍了C#程序优化的五十个需要注意的地方，使用c#开发的朋友可以看下2013-09-09
这篇文章介绍了在WPF中使用Interaction.Triggers的方法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2022-06-06
这篇文章主要为大家详细介绍了C#如何使用selenium组件实现操作浏览器并且截图,文中的示例代码简洁易懂,有需要的小伙伴可以参考一下2024-01-01
这篇文章主要为大家详细介绍了C#操作INI文件的辅助类IniHelper，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2018-03-03
这篇文章主要给大家介绍了关于C# 4.0新特性“缺省参数”的实现，文中通过示例代码介绍的非常详细，对大家学习或者使用C# 4.0具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧2020-06-06
这篇文章主要为大家详细介绍了C#无损高质量压缩图片代码，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-05-05
![浅谈C#中[]的几种用法](http://img.jbzj.com/images/xgimg/bcimg3.png)
最新评论