並行編程簡單用法及異常處理，並行用法異常處理

並行編程簡單用法及異常處理，並行用法異常處理

當有大量的數據需要處理或者有大量任務需要完成，而且每塊數據或每個任務是彼此獨立的，這時候可以考慮使用並行編程。現代計算機都是多核的，並行編程可以提高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;
    );
}