溫馨提示×

溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》

怎么實現(xiàn)C# 并行任務(wù)的Parallel類

發(fā)布時間：2020-07-10 11:03:18 來源：億速云 閱讀：559 作者：Leah 欄目：編程語言

本篇文章給大家分享的是有關(guān)怎么實現(xiàn)C# 并行任務(wù)的Parallel類，小編覺得挺實用的，因此分享給大家學(xué)習(xí)，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。

                                                           一、Parallel類

Parallel類提供了數(shù)據(jù)和任務(wù)的并行性；

二、Paraller.For()

Paraller.For()方法類似于C#的for循環(huán)語句，也是多次執(zhí)行一個任務(wù)。使用Paraller.For()方法，可以并行運行迭代，迭代的順序沒有定義。

在For()方法中，前兩個參數(shù)是固定的，這兩個參數(shù)定義了循環(huán)的開頭和結(jié)束。首先描述它的第一個方法For(int,int,Action<int>)，前面兩個參數(shù)代表循環(huán)的開頭和介紹，第三個參數(shù)是個委托，整數(shù)參數(shù)是循環(huán)的迭代次數(shù)，該參數(shù)被傳遞給委托引用的方法。Paraller.For()方法的返回類型是ParallelLoopResult結(jié)構(gòu)，它提供了循環(huán)是否結(jié)束的信息和最低迭代的索引（返回一個表示從中調(diào)用 Break 語句的最低迭代的整數(shù)）。先寫個例子：

            ParallelLoopResult result = Parallel.For(0, 10, i =>{
                Console.WriteLine("迭代次數(shù)：{0},任務(wù)ID:{1},線程ID:{2}", i, Task.CurrentId, Thread.CurrentThread.ManagedThreadId);
                Thread.Sleep(10);
            });

            Console.WriteLine("是否完成:{0}", result.IsCompleted);
            Console.WriteLine("最低迭代:{0}", result.LowestBreakIteration);

輸出結(jié)果如下：

怎么實現(xiàn)C# 并行任務(wù)的Parallel類

可以看到，該委托方法運行了10次，順序也是不能被保證的。但是最低迭代并沒有數(shù)據(jù)出來，這是因為他是返回調(diào)用 Break 語句的最低迭代的整數(shù)，在這我們并沒有break。如果需要才執(zhí)行過程中提前中斷For()方法，就可以使用ParallelLoopState來實現(xiàn),For(int,int,Action<int,ParallelLoopState>)。就上面的例子改一下：

            ParallelLoopResult result = Parallel.For(0, 10, (i, state) =>{
                Console.WriteLine("迭代次數(shù)：{0},任務(wù)ID:{1},線程ID:{2}", i, Task.CurrentId, Thread.CurrentThread.ManagedThreadId);
                Thread.Sleep(10);if (i > 5)
                    state.Break();
            });

            Console.WriteLine("是否完成:{0}", result.IsCompleted);
            Console.WriteLine("最低迭代:{0}", result.LowestBreakIteration);

輸出結(jié)果如下：

怎么實現(xiàn)C# 并行任務(wù)的Parallel類

三、Parallel.ForEach()

Paraller.ForEach()方法遍歷實現(xiàn)了IEnumerable的集合，其方法類似于 foreach的語句，但以異步方式遍歷，這里也沒有確定遍歷順序。首先描述它的第一個方法，Paraller.ForEach<TSource>(IEnumerable<TSource>,Action<TSource>)，先看下面的例子；

            string[] data = { "str1", "str2", "str3" };
            ParallelLoopResult result = Parallel.ForEach<string>(data, str =>  {
                  Console.WriteLine(str);
              });
            Console.WriteLine("是否完成:{0}", result.IsCompleted);
            Console.WriteLine("最低迭代:{0}", result.LowestBreakIteration);

輸出結(jié)果如下：

怎么實現(xiàn)C# 并行任務(wù)的Parallel類

它也可以像For一樣傳入迭代次數(shù)和ParallelLoopState的，方法是ForEach<TSource>(IEnumerable<TSource> source, Action<TSource, ParallelLoopState, long> body)，接著在上面的例子改動

            string[] data = { "str1", "str2", "str3", "str4", "str5" };
            ParallelLoopResult result = Parallel.ForEach<string>(data, (str, state, i) =>  {
                  Console.WriteLine("迭代次數(shù)：{0},{1}", i, str);                  if (i > 3)
                      state.Break();
              });
            Console.WriteLine("是否完成:{0}", result.IsCompleted);
            Console.WriteLine("最低迭代:{0}", result.LowestBreakIteration);

輸出結(jié)果如下：

怎么實現(xiàn)C# 并行任務(wù)的Parallel類

四、Parallel.Invoke()

Parallel.Invoke()方法，它提供了任務(wù)并行性模式。Paraller.Invoke()方法允許傳遞一個Action委托數(shù)組，在其中可以指定應(yīng)運行的方法，看下面的例子

            Parallel.Invoke(() =>{
                Thread.Sleep(100);
                Console.WriteLine("method1");
            }, () =>{
                Thread.Sleep(10);
                Console.WriteLine("method2");
            });

輸出結(jié)果如下：

怎么實現(xiàn)C# 并行任務(wù)的Parallel類

五、結(jié)語

Parallel.For()和Paraller.ForEach()方法在每次迭代中調(diào)用相同的代碼，而Parallel.Invoke()方法允許同時調(diào)用不同的方法。Parallel.ForEach()用于數(shù)據(jù)并行性，Parallel.Invoke()用于任務(wù)并行性；

以上就是怎么實現(xiàn)C# 并行任務(wù)的Parallel類，小編相信有部分知識點可能是我們?nèi)粘９ぷ鲿姷交蛴玫降?。希望你能通過這篇文章學(xué)到更多知識。更多詳情敬請關(guān)注億速云行業(yè)資訊頻道。

向AI問一下細(xì)節(jié)

免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點不代表本網(wǎng)站立場，如果涉及侵權(quán)請聯(lián)系站長郵箱：is@yisu.com進(jìn)行舉報，并提供相關(guān)證據(jù)，一經(jīng)查實，將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI
助
手