你的位置:首页 > ASP.net教程

[ASP.net教程]并行编程简单用法及异常处理


 

当有大量的数据需要处理或者有大量任务需要完成,而且每块数据或每个任务是彼此独立的,这时候可以考虑使用并行编程。现代计算机都是多核的,并行编程可以提高CPU利用率以提高吞吐量。

 

Parallel.Invoke形参能接收一个Action数组。

 

    static void Main(string[] args)
    {
      Test();
      Console.ReadKey();
    }
    static void M1()
    {
      Console.WriteLine("方法1");
    }
    static void M2()
    {
      Console.WriteLine("方法2");
    }
    static void M3()
    {
      Console.WriteLine("方法3");
    }
    static void Test()
    {
      Parallel.Invoke(M1,M2,M3);
    }

 

需要注意的是,Parallel.Invoke是一个同步方法,需要等所有委托执行完毕才返回结果。

 

Parallel.Invoke还接收一个ParallelOptions类型的形参,用来控制整个并行过程。

 

MaxDegreeOfParallelism属性用来设置使用最多多少的线程。
TaskScheduler属性用来设置何时哪个线程执行。
CancellationToken属性,一旦在某个委托中设置取消整个并行过程。

 

以下,就是一个使用CancellationToken属性的例子。

 

    static void Main(string[] args)
    {
      Test();
      Console.ReadKey();
    }
    static void M1()
    {
      token.Cancel();
    }
    static void M2()
    {
      Console.WriteLine("方法2");
    }
    static void M3()
    {
      Console.WriteLine("方法3");
    }
    static CancellationTokenSource token = new CancellationTokenSource();
    static void Test()
    {
      ParallelOptions op = new ParallelOptions();
      op.CancellationToken = token.Token;
      try
      {
        Parallel.Invoke(op,M1, M2, M3);
      }
      catch (OperationCanceledException ex)
      {
        Console.WriteLine(ex);
      }
      
    }

 

以上,通过调用CancellationTokenSource的实例方法Cancel,取消某个委托的执行,一旦Parallel.Invoke方法接收ParallelOptions类型的实参,就可以取消整个并行动作。

 

Parallel.Invoke适合在遇到大量任务,且每个任务是相互独立的时候使用。


而通常情况下,Parallel.ForEach适合在遇到需要处理大量数据,且每块数据是相互独立的时候使用。

 

    static void Main(string[] args)
    {
      IEnumerable<int> lst = new List<int> {1, 2, 3,4,5,6};
      Parallel.ForEach(lst, i => DisplayDigit(i));
      Console.ReadKey();
    }
    static void DisplayDigit(int i)
    {
      Console.WriteLine(i);
    }

 

Parallel.For用于当数据处理过程基于索引的时候。

 

在.NET中把并行的异常统统打包在AggregationException中。大致这样处理异常:

 

try
{
  Parallel.Invoke(
    () => throw new Exception();
    () => throw new Exception();
  );
}
catch(AggregateException ex)
{
  ex.Handle(
    exception => Console.WriteLine(ex);
    return true;
  );
}