并行循环

Posted 2021-03-16 ccaa

上次我们讲到了集合。说到集合，那往往少不了循环。今天我们说下什么是并行循环

Parallel.For，Paraller.Foreach 

(System.Threading.Tasks)

相信大家对此都不陌生。

 long sum = 0;
            Parallel.For(0, MaxValue, (i) =>
            {
                Interlocked.Add(ref sum, (long)Math.Sqrt(i));
                values.Add(i);
            });

也可以Paraller.Foreach.

中断循环:

如果需要中断循环，可以给循环的委托传入一个ParallelLoopState对象，中止循环。有两个方法。

Break,Stop；区别是什么呢？

1：Break---告诉循环不要执行大于当前迭代次数的任何迭代。啥意思呢。就是大于i 的都会停止运行，小于i的依然会执行。注意：可能会有多个循环迭代发起Break调用，要看代码逻辑了。

2:Stop:----停止任何迭代。

 问题调整

 ~对了。在使用并行循环的时候，要确保每次迭代的工作量要明显大于同步共享状态的开销。如果你把循环的时间都耗在阻塞共享的循环变量上，那并行执行也就没意义了。所以每次迭代都进行局部访问，

~并行循环还有另一个问题，就是委托。每次都会生成一个委托，如果每次迭代完成的工作还不如生成委托的开销大。那就是杀鸡用牛刀。大材小用。

说下委托的开销吧。委托的开销分为两种：构造开销和调用开销，调用和普通方法调用差不多。构造开销就很大。你应该只做一次构造，并把对象缓存起来。把委托定义在循环外。

上面的问题怎么解决呢？

用Partitioner类，它会把需要的迭代的区间分拆存入Tuple对象种。

public static void Main()
  {
    Stopwatch watch=new Stopwatch();
    const int MaxValue=10000000;
    long sum=0;

    //普通循环
    watch.Restart();
    sum=0;
    Parallel.For(0,MaxValue,(i)=>{
      Interlocked.Add(ref sum,(long)Math.Sqrt(i));
    });
    watch.Stop();
    Console.WriteLine("Parallel.For:{0}",watch.Elapsed);
    
    //分区的For循环
    var partitioner=Partitioner.Create(0,MaxValue);
    watch.Restart();
    sum=0;
    Parallel.ForEach(partitioner,(range)=>{
      long partialSum=0;
      for(int i=range.Item1;i<range.Item2;i++)
      {
        partialSum+=(long)Math.Sqrt(i);
      }
      Interlocked.Add(ref sum,partialSum);
    });
    watch.Stop();
    Console.WriteLine("Partitioned Parallel.For:{0}",watch.Elapsed);
  }

 

 我的电脑上执行的结果。

上面分区规则是静态的，只要迭代区间划分完毕，每个区间都运行一个委托。其中有一个提前完成，也不会尝试重新分区。