浅谈.Net并行计算之数据并行
从第一台计算机问世到现在计算机硬件技术已经有了很大的发展。不管是现在个人使用的pc还是公司使用的服务器。双核，四核,八核的cpu已经非常常见。这样我们可以将我们程序分摊到多个计算机cpu中去计算，在过去并行化需要线程的低级操作，难度很大，在.net4.0中的增强了对并行化的支持，使得这一切变得非常简单 。本次我从以下几个方面大家讲以下.net 并行
1. 数据并行
2. 任务并行
3. 并行linq
4. 任务工厂
5. 注意事项
本次主要给大家讲一下数据并行 废话不说，下面开始了
数据并行其实就是指对原集合或者数组中的数据进行划区之后分摊到多个cpu或者多个线程执行相同的操作 在 .net中的 system.threading.tasks 提供了对数据并行的支持类 ， parallel.for，parallel.foreach和我们经常的使用的for 和foreach 十分的相似，你不用创建线程队列，在基本的循环中你不用使用锁。这些.net 会帮你处理，你只需要关注你自己的业务 那下面我们就来看看 parallel.for 和 parallel.foreach 是如何使用的
• parallel.for 简单使用
parallel.for(0, 100, i => {
dosameting()
});
上面的例子是不是和我们经常使用的for循环的影子。 说一下 parallel.for 的第三个参数action<int>类型的委托 不管这个委托的参数是0个还是多少个他的返回植都是void，那么怎么样才能获取到parallel.for 中的的返回值了，下面的例子将演示如何使用线程本地变量来存储和检索由 for 循环创建的每个单独任务中的状态 通过使用线程本地数据，您可以避免将大量的访问同步为共享状态的开销。 在任务的所有迭代完成之前，您将计算和存储值，而不是写入每个迭代上的共享资源。 然后，您可以将最终结果一次性写入共享资源，或将其传递到另一个方法
•对个list<int> 进行求和我们这里假设list的长度为listlength
parallel.for<long>(0, listlength, () => 0, (j, loop, subsum) =>
{
subsum += lista[j];
return subsum;
}, (x) => interlocked.add(ref sum, x));
•在现实中我们也经常会遇到需要取消循环的情况。比如你在队列中查找一个数。那么如何退出parallel.for 循环了。是不是也是和for 和foreach那样 使用break关键字就可以了，答案否定的。这是因为break 构造对循环是有效的，而并行循环其实是一个方法，并不是循环 那么要怎么样取消了。请看下面的例子
parallel.for<long>(0, listlength, () => 0, (j, loop, subsum) =>
{
if (subsum > 20000)
{
loop.break();
}
subsum += lista[j];
return subsum;
}, (x) => interlocked.add(ref sum, x));
• 简单parallel.foreach 循环 parallel.foreach循环的工作方式类似于 parallel.for 循环 根据系统环境，对源集合进行分区，并在多个线程上计划工作。 系统中的处理器越多，并行方法的运行速度越快。 对于某些源集合，顺序循环可能更快，具体取决于源的大小和正在执行的工作类型
parallel.foreach(lista, i => { dosameting(); });
不知道大家在这个地方有没有看到foreach的影子。其实上面的例子中的foreach方法的最后一个输入参数是 action<int>委托，当所有循环完成时，方法将调用该委托。这个地方和前面的parallel.for 是一样的。那么我们要如何获得返回值了和上面的for是非常相似，我依然以上面数组求和为例
parallel.foreach<int, long>(lista, () => 0, (j, loop, subsum) =>
{
if (subsum > 20000)
{
loop.break();
}
subsum += lista[j];
return subsum;
}, (x) => interlocked.add(ref sum, x));
• parallel.for 和for 性能测试比较 我们这里产生1千万个随机数为例子做个一个性能比较，在笔者的笔记本上结果如下 （可能在你的电脑上得到结果不一定相同）
附上相关的代码给大家参考
int listlength = 10000000;
list<int> listtask = new list<int>();
list<int> list = new list<int>();
stopwatch watch1 = stopwatch.startnew();
parallel.for(0, listlength, i => {
random r = new random(100);
listtask.add(r.next());
});
console.writeline("并行耗时:" + watch1.elapsedmilliseconds );
stopwatch watch2 = stopwatch.startnew();
for (int i = 0; i < listlength; i++)
{
random r = new random(100);
list.add(r.next());
}
console.writeline("非并行耗时:" + watch2.elapsedmilliseconds );
推荐阅读