C#並行庫Parallel類介紹
Parallel.Invoke
這個函數的功能和Task有些相似,就是並發執行一系列任務,然後等待所有完成。和Task比起來,省略瞭Task.WaitAll這一步,自然也缺少瞭Task的相關管理功能。它有兩種形式:
Parallel.Invoke( params Action[] actions); Parallel.Invoke(Action[] actions,TaskManager manager,TaskCreationOptions options);
第二種方式可以自定義一個TaskManager對任務的執行線程進行管理(第一種方式用的是默認的TaskManager.Default)。
示例如下:
static void Main(string[] args) { var actions = new Action[]{ () => ActionTest("test 1"), () => ActionTest("test 2"), () => ActionTest("test 3"), () => ActionTest("test 4")}; Console.WriteLine("Parallel.Invoke 1 Test"); Parallel.Invoke(actions); Console.WriteLine(); Console.WriteLine("Parallel.Invoke 2 Test"); Parallel.Invoke(actions, new TaskManager(new TaskManagerPolicy(1, 1, 2)), TaskCreationOptions.None); } static void ActionTest(object value) { Console.WriteLine(">>> thread:{0}, value:{1}", Thread.CurrentThread.ManagedThreadId, value); }
輸出結果如下:
Parallel.Invoke 1 Test
>>> thread:3, value:test 1
>>> thread:3, value:test 2
>>> thread:4, value:test 3
>>> thread:5, value:test 4Parallel.Invoke 2 Test
>>> thread:7, value:test 1
>>> thread:7, value:test 2
>>> thread:8, value:test 3
>>> thread:7, value:test 4
可見,由於第二次指定瞭最多隻能使用兩個線程來執行,故隻有兩個Task並發執行。
Parallel.ForEach和Parallel.For
Parallel.ForEach和Parallel.For用得要更加廣泛一些,他可以根據一個數據源來生成一些任務(Parallel.Invoke需要事先生成這些任務),同時並發執行這些任務。基本示例如下:
static void Main(string[] args) { var data = new object[] { "test 1", "test 2", "test 3" }; Console.WriteLine("Parallel.ForEach Test"); Parallel.ForEach(data, item => ActionTest(item)); Console.WriteLine(); Console.WriteLine("Parallel.For Test"); Parallel.For(0, data.Length, index => ActionTest(data[index])); }
這兩個函數都有多種重載形式,提供瞭許多控制功能,由於用得不是很多,這裡就不一一介紹瞭。但有一點不是很好:如果需要用TaskManager的話,不得不用那最復雜的那一種形式。希望最終版本的時候會提供更合理的重載形式,畢竟TaskManager還是很常用的(雖然目前的TaskManager功能薄弱瞭點),而那些復雜的參數不是很常用的。因此,這裡提供瞭兩個常用的擴展方法的封裝:
public static class ParallelExtend { public static void ParallelForEach<T>(this IEnumerable<T> source, Action<T> hanlder) { Parallel.ForEach(source, hanlder); } public static void ParallelForEach<T>(this IEnumerable<T> source, Action<T> hanlder, TaskManagerPolicy policy) { using (var manager = new TaskManager(policy)) { Parallel.ForEach(source, () => 0, (item, index, state) => hanlder(item), local => { }, manager, TaskCreationOptions.None); } } }
通過擴展方法的方式用起來還是比較方便的。
到此這篇關於C#並行庫Parallel類的文章就介紹到這瞭。希望對大傢的學習有所幫助,也希望大傢多多支持WalkonNet。
推薦閱讀:
- c# 並行和多線程編程——認識Parallel
- .Net中Task Parallel Library的基本用法
- c#中task與thread區別及其使用的方法示例
- C#中Task.ContinueWith連續任務使用實例
- C# 異步多線程入門基礎