个人中心
gpt4 book ai didi

浅谈.Net并行计算之数据并行

转载 作者：qq735679552 更新时间：2022-09-29 22:32:09 30 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章浅谈.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 ),

  。

最后此篇关于浅谈.Net并行计算之数据并行的文章就讲到这里了,如果你想了解更多关于浅谈.Net并行计算之数据并行的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

30 4 0
文章推荐： c#将Excel数据导入到数据库的实现代码
文章推荐： C#实现上传照片到物理路径，并且将地址保存到数据库的小例子
文章推荐： 关于 尝试读取或写入受保护的内存。这通常指示其他内存已损坏。的解决方法
文章推荐： .NET 日志系统设计思路及实现代码
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com