国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 學院 > 開發設計 > 正文

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

2019-11-14 14:10:56
字體:
來源:轉載
供稿:網友

 

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

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 锡林浩特市| 饶河县| 丽水市| 遂平县| 松原市| 武平县| 宁强县| 龙里县| 个旧市| 资阳市| 彰化市| 长顺县| 汝阳县| 绿春县| 绥阳县| 镇安县| 什邡市| 永春县| 酒泉市| 衡阳市| 富川| 广平县| 阜阳市| 洪江市| 夹江县| 辰溪县| 新野县| 邵武市| 新巴尔虎右旗| 通山县| 西丰县| 文安县| 滦南县| 韶山市| 根河市| 榆中县| 八宿县| 渝中区| 女性| 沈阳市| 安康市|