国产探花免费观看_亚洲丰满少妇自慰呻吟_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;
    );
}

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 汤阴县| 元阳县| 永春县| 钟山县| 田林县| 汶川县| 息烽县| 安新县| 荆州市| 涟源市| 大化| 柘城县| 平江县| 永兴县| 邛崃市| 仙游县| 青河县| 五大连池市| 蓝田县| 新丰县| 明溪县| 重庆市| 施秉县| 棋牌| 永康市| 恩施市| 中牟县| 阳新县| 东莞市| 聊城市| 浦北县| 郁南县| 肇源县| 鲜城| 积石山| 荣成市| 黄平县| 织金县| 两当县| 合川市| 肃宁县|