C# Task 的用法(轉自:http://www.wxzzz.com/683.html#)
其實Task跟線程池ThreadPool的功能類似,不過寫起來更為簡單,直觀。代碼更簡潔了,使用Task來進行操作。可以跟線程一樣可以輕松的對執行的方法進行控制。
順便提一下,配合CancellationTokenSource類更為可以輕松的對Task操作的代碼進行中途終止運行,會在后面的章節中講述。
如果我們使用線程池來實現某幾個方法運行,然后等待運行完成的大概會編寫如下代碼:
- using (ManualResetEvent m1 = new ManualResetEvent(false))
- using (ManualResetEvent m2 = new ManualResetEvent(false))
- {
- ThreadPool.QueueUserWorkItem(delegate
- {
- MyMethodA();
- m1.Set();
- });
- ThreadPool.QueueUserWorkItem(delegate
- {
- MyMethodB();
- m2.Set();
- });
- WaitHandle.WaitAll(new WaitHandle[] { m1, m2, });
- }
如果用Task類的話,相對就比較簡單了,至少代碼看起來很舒服。也就意味着維護也比較方便
- Task t1 = Task.Factory.StartNew(delegate { MyMethodA(); });
- Task t2 = Task.Factory.StartNew(delegate { MyMethodB(); });
- t1.Wait();
- t2.Wait();
上面的方法是一個一個的執行完畢,獲取不是我們想要的,我們一般是想要他們一起同時執行,提高程序處理事情的效率。
- Task t1 = Task.Factory.StartNew(delegate { MyMethodA(); });
- Task t2 = Task.Factory.StartNew(delegate { MyMethodB(); });
- Task.WaitAll(t1, t2);
下面我們來簡單介紹下Task的用法
創建 Task
創建Task有兩種方式,一種是使用構造函數創建,另一種是使用 Task.Factory.StartNew 進行創建。如下代碼所示
1.使用構造函數創建Task
- Task t1 = new Task(MyMethod);
2.使用Task.Factory.StartNew 進行創建Task
- Task t1 = Task.Factory.StartNew(MyMethod);
其實這兩種方式都是一樣的,Task.Factory 是對Task進行管理,調度管理這一類的。好學的伙伴們,可以深入研究。這不是本文的范疇,也許會在后面的文章細說。
運行 Task
運行Task的兩種方式,在上面我們已經提到過了,一種等待運行完畢,另一種則等待所有運行完畢。不過這里還有一種就是異步運行,跟使用多線程一樣,調用Task對象中的Start()方法即可。看看下面這個控制台示例。純粹是Wait和AllWait的話,僅僅是等待。而不是執行。所以我們還需要調用Start()方法
- static void Main(string[] args)
- {
- Task t1 = new Task(MyMethod);
- t1.Start();
- Console.WriteLine("主線程代碼運行結束");
- Console.ReadLine();
- }
- static void MyMethod()
- {
- for (int i = 0; i < 5; i++)
- {
- Console.WriteLine(DateTime.Now.ToString());
- Thread.Sleep(1000);
- }
- }
運行效果如圖
取消Task
我們一開始就描述了 CancellationTokenSource 這個對象對Task的取消運行。一般是用不到這個方法的,一般會正常的退出所運行的代碼,如使用 bool IsExit 之類的來進行一個控制。而不是中途強制中斷代碼。
可以參考我的這篇文章:http://www.wxzzz.com/643.html
至於 CancellationTokenSource 控制Task,下一篇文章會進行詳細的一個介紹。
Task的異常處理
因為Task中是異步執行,你也可以理解為跟多線程一樣,具體錯誤捕獲需要自己去捕獲。很有意思的是Task的異常還會重新拋到Wait和AllWait中,我們可以進行方便的捕獲這些異常。如下代碼
- static void Main(string[] args)
- {
- Task t1 = new Task(MyMethod);
- t1.Start();
- t1.Wait();
- Console.WriteLine("主線程代碼運行結束");
- Console.ReadLine();
- }
- static void MyMethod()
- {
- throw new Exception("Task異常測試");
- }
運行效果如圖
獲取 Task 的返回值
先看看代碼
- Task<string> t1 = Task.Factory.StartNew(() => "測試");
- t1.Wait();
- Console.WriteLine(t1.Result);
- Console.ReadLine();
返回值可以是任意的類型,因為是個泛型嘛~ 還是依然的非常簡潔的代碼。
至此,就是 C# Task 的相關用法了,歡迎回復討論。