您好,登錄后才能下訂單哦!
這篇“c#中Task.Wait()與awaiat Task異常處理的區(qū)別是什么”文章的知識點(diǎn)大部分人都不太理解,所以小編給大家總結(jié)了以下內(nèi)容,內(nèi)容詳細(xì),步驟清晰,具有一定的借鑒價(jià)值,希望大家閱讀完這篇文章能有所收獲,下面我們一起來看看這篇“c#中Task.Wait()與awaiat Task異常處理的區(qū)別是什么”文章吧。
下面有兩個(gè)例子代碼,可以直接復(fù)制粘貼到.net core中運(yùn)行。兩個(gè)代碼要實(shí)現(xiàn)的功能完全一樣,但是內(nèi)核卻又很大差異。
先看下面用await的例子與輸出:
using System; using System.Threading; using System.Threading.Tasks; class Program { static async Task Main() { System.Console.WriteLine($"Main Task ID:{Thread.CurrentThread.ManagedThreadId}"); var task = Task.Run(() => { System.Console.WriteLine($"In Task.Run(), Task ID:{Thread.CurrentThread.ManagedThreadId}"); int[] vary=new int[5]; while (true) { Thread.Sleep(3000); int d = vary[6]; } }); // Just continue on this thread, or await with try-catch: try { await task; } catch (IndexOutOfRangeException ex) { System.Console.WriteLine(ex.Message); System.Console.WriteLine($"After Wait(), Task ID:{Thread.CurrentThread.ManagedThreadId}"); } catch(AggregateException ex) { System.Console.WriteLine(ex.Message); System.Console.WriteLine($"After Wait(), Task ID:{Thread.CurrentThread.ManagedThreadId}"); } finally { //... } System.Console.WriteLine("Reach end."); Console.ReadKey(); } } /* Main Task ID:1 In Task.Run(), Task ID:4 Index was outside the bounds of the array. Catch System.IndexOutOfRangeException After Wait(), Task ID:4 Reach end. */
再看Task.Wait()方法下的異常處理與輸出:
using System; using System.Threading; using System.Threading.Tasks; class Program { static void Main() { System.Console.WriteLine($"Main Task ID:{Thread.CurrentThread.ManagedThreadId}"); var task = Task.Run(() => { System.Console.WriteLine($"In Task.Run(), Task ID:{Thread.CurrentThread.ManagedThreadId}"); int[] vary=new int[5]; while (true) { Thread.Sleep(3000); int d = vary[6]; } }); // Just continue on this thread, or await with try-catch: try { task.Wait(); } catch (IndexOutOfRangeException ex) { System.Console.WriteLine($"Catch {ex.GetType()}"); System.Console.WriteLine($"After Wait(), Task ID:{Thread.CurrentThread.ManagedThreadId}"); } catch(AggregateException ex) { System.Console.WriteLine($"Catch {ex.GetType()}"); System.Console.WriteLine($"After Wait(), Task ID:{Thread.CurrentThread.ManagedThreadId}"); } finally { //... } System.Console.WriteLine("Reach end."); Console.ReadKey(); } } /* Main Task ID:1 In Task.Run(), Task ID:4 Catch System.AggregateException One or more errors occurred. (Index was outside the bounds of the array.) After Wait(), Task ID:1 Reach end. */
從例子中可以看出,await之后的代碼其實(shí)都是在新的線程(4線程)中執(zhí)行,而Task.Wait()方法后的線程則是在主線程中執(zhí)行。
因此,await之后的代碼完全以傳統(tǒng)方式處理異常;而Task.Wait()拋出的異常則由于是從新線程往外部線程拋出,所以它是被重新封裝為AggregateException異常拋出。
使用Task.WaitAll() 等待多任務(wù)執(zhí)行完畢的時(shí)候發(fā)現(xiàn),等待的任務(wù)還沒結(jié)束,Task.WaitAll() 就先結(jié)束了,于是就寫了一段測試代碼進(jìn)行驗(yàn)證。
static void Main(string[] args) { //建立兩個(gè)任務(wù) Task t1 = new Task(async () => await T1()); Task t2 = new Task(async () => await T2()); //啟動(dòng)任務(wù) t1.Start(); t2.Start(); //等待任務(wù)完成 Task.WaitAll(t1, t2); Print("WaitAll Done"); Console.ReadLine(); } static async Task T1() { Print("T1 Start"); Thread.Sleep(1000); Print("T1 await"); await Task.Delay(1000); Print("T1 Done"); } static async Task T2() { Print("T2 Start"); Thread.Sleep(1000); Print("T2 await"); await Task.Delay(1000); Print("T2 Done"); } static void Print(string msg) { Console.WriteLine($"{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.ffffff")}: {msg}"); }
再上結(jié)果,注意看T1、T2 Done 和 WaitAll Done的打印時(shí)間:
果然,坑!
Task.WaitAll() 盡然比等待的Task先結(jié)束。
總結(jié):(不推薦,請看補(bǔ)充內(nèi)容)
new Task().Start() 中一旦使用 await ,會立馬返回結(jié)束狀態(tài)。
所以,在使用 Task.WaitAll() 或其接續(xù)任務(wù)的時(shí)候,可以考慮使用 Thead.sleep() 替代 await Task.Delay() 。
2022-04-25 補(bǔ)充:
經(jīng)過【32號就放假】提醒,測試了Task.Run() 和 Task.Factory.StartNew()兩個(gè)方法,得出結(jié)論:
1、 在Task.Run()啟動(dòng)任務(wù)中,await會正常運(yùn)行;(推薦使用)
static void Main(string[] args) { //建立兩個(gè)任務(wù) Task t1 = Task.Run(T1); Task t2 = Task.Run(T2); //等待任務(wù)完成 Task.WaitAll(t1, t2); Print("WaitAll Done"); Console.ReadLine(); }
2、在Task.Factory.StartNew() 啟動(dòng)任務(wù)中,會立馬返回結(jié)束狀態(tài)。
static void Main(string[] args) { //建立兩個(gè)任務(wù) Task t1 = Task.Factory.StartNew(T1); Task t2 = Task.Factory.StartNew(T2); //等待任務(wù)完成 Task.WaitAll(t1, t2); Print("WaitAll Done"); Console.ReadLine(); }
以上就是關(guān)于“c#中Task.Wait()與awaiat Task異常處理的區(qū)別是什么”這篇文章的內(nèi)容,相信大家都有了一定的了解,希望小編分享的內(nèi)容對大家有幫助,若想了解更多相關(guān)的知識內(nèi)容,請關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。