C#學習之Task 的用法1
阿新 • • 發佈：2019-01-26
其實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(); });
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 進行建立。如下程式碼所示
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因為我們沒有呼叫Wait 所以是非同步執行的~取消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 Exception獲取 Task 的返回值先看看程式碼Task<string> t1 = Task.Factory.StartNew(() => "測試");
t1.Wait();
Console.WriteLine(t1.Result);
Console.ReadLine();
返回值可以是任意的型別，因為是個泛型嘛~ 還是依然的非常簡潔的程式碼。
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(); });
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 進行建立。如下程式碼所示
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因為我們沒有呼叫Wait 所以是非同步執行的~取消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 Exception獲取 Task 的返回值先看看程式碼Task<string> t1 = Task.Factory.StartNew(() => "測試");
t1.Wait();
Console.WriteLine(t1.Result);
Console.ReadLine();
返回值可以是任意的型別，因為是個泛型嘛~ 還是依然的非常簡潔的程式碼。