C#中Parallel類For、ForEach和Invoke使用介紹
一、簡介:
Parallel類提供了數(shù)據(jù)和任務(wù)的并行性;
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ù))。
二、Paraller.For(int,int,Action<int>):
代碼演示:
public static void Test() { 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é)果:
三、Paraller.For(int,int,Action<int,ParallelLoopState>):
可以看到,上面委托方法運行了10次,順序也是不能被保證的。但是最低迭代并沒有數(shù)據(jù)出來,這是因為他是返回調(diào)用 Break 語句的最低迭代的整數(shù),在這我們并沒有break。如果需要才執(zhí)行過程中提前中斷For()方法,就可以使用ParallelLoopState來實現(xiàn),For(int,int,Action<int,ParallelLoopState>)。
代碼演示:
public static void Test() { 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é)果:
四、Parallel.ForEach()
Paraller.ForEach()方法遍歷實現(xiàn)了IEnumerable的集合,其方法類似于 foreach的語句,但以異步方式遍歷,這里也沒有確定遍歷順序。首先描述它的第一個方法,Paraller.ForEach<TSource>(IEnumerable<TSource>,Action<TSource>),先看下例子:
代碼演示:
public static void Test() { 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é)果:
五、Parallel.ForEach<TSource>
它也可以像For一樣傳入迭代次數(shù)和ParallelLoopState的,方法是ForEach<TSource>(IEnumerable<TSource> source, Action<TSource, ParallelLoopState, long> body)
代碼演示:
public static void Test() { 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é)果:
六、Parallel.Invoke()
Parallel.Invoke()方法,它提供了任務(wù)并行性模式。Paraller.Invoke()方法允許傳遞一個Action委托數(shù)組,在其中可以指定應(yīng)運行的方法,看下面的例子:
代碼演示:
public static void Test() { Parallel.Invoke(() => { Thread.Sleep(100); Console.WriteLine("method1"); }, () => { Thread.Sleep(10); Console.WriteLine("method2"); }); }
運行結(jié)果:
七、總結(jié)
Parallel.For()和Paraller.ForEach()方法在每次迭代中調(diào)用相同的代碼,而Parallel.Invoke()方法允許同時調(diào)用不同的方法。Parallel.ForEach()用于數(shù)據(jù)并行性,Parallel.Invoke()用于任務(wù)并行性。
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
Unity2021發(fā)布WebGL與網(wǎng)頁交互問題的解決
本文主要介紹了Unity2021發(fā)布WebGL與網(wǎng)頁交互問題的解決,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-05-05WPF實現(xiàn)XAML轉(zhuǎn)圖片的示例詳解
這篇文章主要為大家詳細(xì)介紹了如何利用WPF實現(xiàn)XAML轉(zhuǎn)圖片,文中的示例代碼講解詳細(xì),對我們學(xué)習(xí)或工作有一定幫助,感興趣的小伙伴可以了解一下2022-11-11C#中Abstract方法和Virtual方法的區(qū)別
這篇文章介紹了C#中Abstract方法和Virtual方法的區(qū)別,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-04-04C#中使用Lambda表達(dá)式自定義比較器實現(xiàn)兩個列表合并實例
這篇文章主要介紹了C#中使用Lambda表達(dá)式自定義比較器實現(xiàn)兩個列表的合并實例,本文給出示例代碼和運行效果,需要的朋友可以參考下2014-10-10