初识并行循环

并行循环主要用来处理数据并行的，如，同时对数组或列表中的多个数据执行相同的操作。

在C#编程中，我们使用并行类System.Threading.Tasks.Parallel提供的静态方法Parallel.For和Parallel.ForEach来实现并行循环。从方法名可以看出，这两个方法是对常规循环for和foreach的并行化。

简单用法

使用并行循环时需要传入循环范围(集合)和操作数据的委托Action<T>：

Parallel.For(0, 100, i => { Console.WriteLine(i); });

Parallel.ForEach(Enumerable.Range(0, 100), i => { Console.WriteLine(i); });

使用场景

对于数据的处理需要耗费较长时间的循环适宜使用并行循环，利用多线程加快执行速度。

对于简单的迭代操作，且迭代范围较小，使用常规循环更好好，因为并行循环涉及到线程的创建、上下文切换和销毁，使用并行循环反而影响执行效率。

对于迭代操作简单但迭代范围很大的情况，我们可以对数据进行分区，再执行并行循环，减少线程数量。

循环结果

Parallel.For和Parallel.ForEach方法的所有重载有着同样的返回值类型ParallelLoopResult，并行循环结果包含循环是否完成以及最低迭代次数两项信息。

下面的例子使用Parallel.ForEach展示了并行循环的结果。

ParallelLoopResult result = Parallel.ForEach(Enumerable.Range(0, 100), (i,loop) =>{    Console.WriteLine(i + 1);    Thread.Sleep(100);if (i == 30)    {        loop.Break();

    }});Console.WriteLine($"{result.IsCompleted}-{result.LowestBreakIteration}");

值得一提的是，循环的Break()和Stop()只能尽早地跳出或者停止循环，而不能立即停止。

取消循环操作

有时候，我们需要在中途取消循环操作，但又不知道确切条件是什么，比如用户触发的取消。这时候，可以利用循环的ParallelOptions传入一个CancellationToken,同时使用异常处理捕获OperationCanceledException以进行取消后的处理。下面是一个简单的例子。

public static CancellationTokenSource CTSource { get; set; } = new CancellationTokenSource();

public static void CancelParallelLoop(){    Task.Factory.StartNew(() =>    {try        {            Parallel.ForEach(Enumerable.Range(0, 100), new ParallelOptions { CancellationToken = CTSource.Token },                i =>                {                    Console.WriteLine(i + 1);                    Thread.Sleep(1000);                });        }catch (OperationCanceledException oce)        {            Console.WriteLine(oce.Message);        }    });}

static void Main(string[] args){    ParallelDemo.CancelParallelLoop();    Thread.Sleep(3000);    ParallelDemo.CTSource.Cancel();

    Console.ReadKey();}

循环异常收集

并行循环执行过程中，可以捕获并收集迭代操作引发的异常，循环结束时抛出一个AggregateException异常，并将收集到的异常赋给它的内部异常集合InnerExceptions。外部使用时，捕获AggregateException,即可进行并行循环的异常处理。

下面的例子模拟了并行循环的异常抛出、收集及处理的过程。

public static void CaptureTheLoopExceptions(){    ConcurrentQueue<Exception> exceptions = new ConcurrentQueue<Exception>();    Parallel.ForEach(Enumerable.Range(0, 100), i =>    {try        {if (i % 10 == 0)            {throw new Exception($"{DateTime.Now}=> Thread-[{Thread.CurrentThread.ManagedThreadId}] had thrown a exception. [{i}]");            }            Console.WriteLine(i + 1);            Thread.Sleep(100);        }catch (Exception ex)        {            exceptions.Enqueue(ex);        }    });

if (!exceptions.IsEmpty)    {throw new AggregateException(exceptions);    }}

外部处理方式

try{    ParallelDemo.CaptureTheLoopExceptions();}catch (AggregateException aex){foreach (Exception ex in aex.InnerExceptions)    {        Console.WriteLine(ex.Message);    }}

分区并行处理

当循环操作很简单，迭代范围很大的时候，ParallelLoop提供一种分区的方式来优化循环性能。下面的例子展示了分区循环的使用，同时也能比较几种循环方式的执行效率。

public static void PartationParallelLoop(int rangeSize = 10000, int opDuration = 1){

    Stopwatch watch0 = Stopwatch.StartNew();    Parallel.ForEach(Partitioner.Create(Enumerable.Range(0, rangeSize), EnumerablePartitionerOptions.None),        i =>        {            Console.WriteLine($"{DateTime.Now}=> Thread-[{Thread.CurrentThread.ManagedThreadId}] was running. [{i}]");            Thread.Sleep(opDuration);        });    watch0.Stop();

    Stopwatch watch1 = Stopwatch.StartNew();    Parallel.ForEach(Partitioner.Create(Enumerable.Range(0, rangeSize),EnumerablePartitionerOptions.NoBuffering),        i =>        {            Console.WriteLine($"{DateTime.Now}=> Thread-[{Thread.CurrentThread.ManagedThreadId}] was running. [{i}]");            Thread.Sleep(opDuration);        });    watch1.Stop();

    Stopwatch watch2 = Stopwatch.StartNew();    Parallel.ForEach(Enumerable.Range(0, rangeSize),        i =>        {            Console.WriteLine($"{DateTime.Now}=> Thread-[{Thread.CurrentThread.ManagedThreadId}] was running. [{i}]");            Thread.Sleep(opDuration);        });    watch2.Stop();

    Stopwatch watch3 = Stopwatch.StartNew();foreach (int i in Enumerable.Range(0, rangeSize))    {        Console.WriteLine($"{DateTime.Now}=> Thread-[{Thread.CurrentThread.ManagedThreadId}] was running. [{i}]");        Thread.Sleep(opDuration);    }    watch2.Stop();

    Console.WriteLine();    Console.WriteLine($"PartationParallelLoopWithBuffer    => {watch0.ElapsedMilliseconds}ms");    Console.WriteLine($"PartationParallelLoopWithoutBuffer => {watch1.ElapsedMilliseconds}ms");    Console.WriteLine($"NormalParallelLoop                 => {watch2.ElapsedMilliseconds}ms");    Console.WriteLine($"NormalLoop                         => {watch3.ElapsedMilliseconds}ms");}

在 I7-7700HQ + 16GB 配置 VS调试模式下得到下面一组测试结果。

应该根据不同的应用场景选择合适的循环策略，具体如何选择，朋友们可自行体会~

原文地址：https://www.cnblogs.com/chenbaoshun/p/10572639.html

.NET社区新闻，深度好文，欢迎访问公众号文章汇总 http://www.csharpkit.com