C产品在市场上有哪些独特优势？

本文共计860个文字，预计阅读时间需要4分钟。

%E2%80%9CParallel.Invoke%E5%87%BD%E6%95%B0%E8%83%BD%E6%89%A7%E8%A1%8C%E5%BA%8F%E5%88%97%E4%BB%BB%E5%8A%A1%EF%BC%8C%E5%90%8E%E7%AD%89%E5%BE%85%E6%89%80%E6%9C%89%E4%BB%BB%E5%8A%A1%E7%BB%93%E6%9D%9F%E3%80%82%E4%BD%BF%E7%94%A8%E6%97%B6%E4%BB%A3%E8%A1%A8%E7%9A%84%E6%9C%BA%E5%88%B6%E5%AF%B9%E4%BA%86Task.WaitAll%E7%9A%84%E7%BB%B4%E5%AE%9A%EF%BC%8C%E4%BC%9A%E5%A4%9F%E4%BB%A5%E8%8E%B7%E5%BE%97%E6%9B%B4%E5%A4%9F%E9%80%9A%E7%94%A8%E7%9A%84%E7%AE%A1%E7%90%86%E8%83%BD%E5%8A%9B%E3%80%82%E5%9B%BE%E8%A1%A8%E6%98%AF%EF%BC%8C%E2%80%9C

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类的文章就介绍到这了。希望对大家的学习有所帮助，也希望大家多多支持自由互联。