银川 网站建设,网站推广软文,免费的网站有哪些平台,深圳龙岗区租房子多少钱一个月前言#xff1a;最近给客户开发一个伙食费计算系统#xff0c;大概需要计算2000个人的伙食。需求是按照员工的预定报餐计划对消费记录进行检查#xff0c;如有未报餐有刷卡或者有报餐没刷卡的要进行一定的金额扣减等一系列规则。一开始我的想法比较简单#xff0c;直接用一… 前言最近给客户开发一个伙食费计算系统大概需要计算2000个人的伙食。需求是按照员工的预定报餐计划对消费记录进行检查如有未报餐有刷卡或者有报餐没刷卡的要进行一定的金额扣减等一系列规则。一开始我的想法比较简单直接用一个for循环搞定统计结果倒是没问题但是计算出来太慢了需要78分钟。这样系统服务是报超时错误的让人觉得有点不太爽。由于时间也不多就就先提交给用户使用了后面逻辑又增加了计算时间变长整个计算一遍居然要将近10分钟了。这个对用户来说是能接收的原来自己手算需要好几天呢但是我自己接受不了于是就开始优化了怎么优化呢用多线程呗。 一提到多线程最先想到的是Task了毕竟.net4.0以上Task封装了很多好用的方法。但是Task毕竟是多开一些线程去执行任务最后整合结果这样可以快一些但我想更加快速一些于是想到了另外一个对象Parallel。之前在维护代码是确实有遇到过别人写的Parallel.Invoke只是指定这个函数的作用是并发执行多项任务如果遇到多个耗时的操作他们之间又不贡献变量这个方法不错。我的情况是要并发执行一个集合于是就用了List.ForAll 这个方法其实是拓展方法完整的调用为List.AsParallel().ForAll需要先转换成支持并发的集合等同于Parallel.ForEach目的是对集合里面的元素并发执行一系列操作。 于是乎把原来的foreach换成了List.AsParallel().ForAll运行起来果然速度惊人不到两分钟就插入结果了但最后却是报主键重复的错误这个错误的原因是由于使用了并发这个时候变量自增其实是在强着自增当多个线程同时获取到了id值都去自增然后就重复了举个例子如下 int num 1;Listint list new Listint();for (int i 1; i 2000; i){list.Add(i);}Console.WriteLine($num初始值为 num.ToString());list.AsParallel().ForAll(n {num;});Console.WriteLine($不加锁并发{list.Count}次后为 num.ToString());Console.ReadKey(); 这段代码是让一个变量执行2000次自增正常结果应该是2001但实际结果如下 有经验的同学立马能想到需要加锁了C#内置了很多锁对象如lock 互斥锁Interlocked 内部锁Monitor 这几个比较常见lock内部实现其实就是使用了Monitor对象。对变量自增Interlocked对象提供了变量自增自减、或者相加等方法,我们使用自增方法Interlocked.Increment函数定义为int Increment(ref int num),该对象提供原子性的变量自增操作传入目标数值返回或者ref num都是自增后的结果。 在之前的基础上我们增加一些代码 num 1;Console.WriteLine($num初始值为 num.ToString());list.AsParallel().ForAll(n {Interlocked.Increment(ref num);});Console.WriteLine($使用内部锁并发{list.Count}次后为 num.ToString());Console.ReadKey(); 我们来看运行结果 加了锁之后ID重复算是解决了其实别高兴太早由于正常的环境有了ID我们还有用这些ID来构建对象呢于是又写了写代码用集合来添加这些ID为了更真实的模拟生产环境我在forAll里面又加了一层循环代码如下 num 1;Random random new Random();var total 0;var m new ConcurrentBagint();list.AsParallel().ForAll(n {var c random.Next(1, 50);Interlocked.Add(ref total, c);for (int i 0; i c; i){Interlocked.Increment(ref num);m.Add(num);}});Console.WriteLine($使用内部锁并发内部循环{list.Count}次后为 num.ToString());Console.WriteLine($实际值为{total 1});var l m.GroupBy(n n).Where(o o.Count() 1);Console.WriteLine($并发里面使用安全集合ConcurrentBag添加num集合重复值{l.Count()}个);Console.ReadKey(); 上面的代码里面我用到了线程安全集合ConcurrentBagT它的命名空间是using System.Collections.Concurrent尽管使用了线程安全集合但是在并发面前仍然是不安全的到了这里其实比较郁闷了自增加锁安全集合内部应该也使用了锁但还是重复了。有点说不过去了想想多线程执行时有个上下文对象即当多个线程同时执行任务共享了变量他们一开始传进去的对象数值应该是相同的由于变量自增时加了锁所以ID是不会重复了。我猜测问题应该出在Add方法了就是说当num值自增后还没有来得及传出去就已经执行了Add方法故添加了重复变量。于是乎我重新写了段代码让ID自增和集合添加都放到锁里面 num 1;total 0;using (var q new BlockingCollectionint()){list.AsParallel().ForAll(n {var c random.Next(1, 50);Interlocked.Add(ref total, c);for (int i 0; i c; i){// Task.Delay(100);q.Add(Interlocked.Increment(ref num));//可控//lock (objLock)//{// num;// q.Add(num);//}}});q.CompleteAdding();Console.WriteLine($num累计值为{total},并发之后值为{num});var x q.GroupBy(n n).Where(o o.Count() 1);Console.WriteLine($并发使用安全集合BlockingCollectionInterlocked添加num集合重复值{x.Count()}个);Console.ReadKey();} 这里我测试了另外一个线程安全的集合BlockingCollection关于这个集合的使用请自行查找MSDN文档上面的关键代码直接添加安全集合的返回值可以保证集合不会重复但其实下面的lock更适用与正式环境因为我们添加的一般都是对象不会是基础类型数值运行结果如下 至此我们的问题解决了计算时间由原来的9分多降至110秒左右可见Parallel的处理还是很给力的唯一不足的是很占CPU执行计算后CPU达到了88%。附上计算结果 优化前后对比 总结C#安全集合在并发的情况下其实不一定是安全的还是需要结合实际应用场景和验证结果为准。Parallel.ForEach在对循环数量可观的情况下是可以去使用的如果有共享变量一定要配合锁做同步处理。还是得慎用这个方法如果方法内部有操作数据库的记得增加事务处理否则就呵呵了。 转载于:https://www.cnblogs.com/heweijian/p/11330282.html
