Task 編程中的異常處理


在 .Net 開發中, 使用 Task 、 Task<T> 進行異步編程是非常方便的, 但是在處理 Task 產生的異常時, 需要注意一個問題, 比如下面的代碼:

static Task<int> TestAsync(int a, int b) {
   var tcs = new TaskCompletionSource<int>();
   Task.Factory.StartNew(() => {
      if (a + b < 0) {
         tcs.TrySetException(new InvalidOperationException("a + b < 0"));
      }
      else {
         tcs.TrySetResult(a + b);
      }
   });
   return tcs.Task;
}

當輸入的兩個參數之和小於 0 時, tcs 會設置一個 InvalidOperationException , 如果直接運行這段代碼, 當這個函數返回的 Task 被 GC 回收時, 將會產生 AggregateException was unhandled 的異常, 運行代碼如下:

static void Main(string[] args) {

   TestAsync(5, -10);

   Thread.Sleep(TimeSpan.FromMilliseconds(3000));

   GC.Collect();

   Console.WriteLine("Completed.");
}

當程序運行結束時, 會產生下圖所示的異常:

2012-07-05_130006

關鍵的是這段文字:

A Task's exception(s) were not observed either by Waiting on the Task or accessing its Exception property. As a result, the unobserved exception was rethrown by the finalizer thread.

沒有在等待 Task 完成時捕獲其異常, 也沒有讀取 Task 的 Exception 屬性, 結果導致異常被終結線程重新拋出。 也就是說, Task 異常有兩種處理方式:

1、 調用 Task 的 Wait 方法時使用 try-catch 捕獲異常:

var testTask = TestAsync(5, -10);
try {
   testTask.Wait();
}
catch(Exception ex) {
   Console.WriteLine(ex);
}

2、 在 Task 的 ContinueWith 方法中讀取 Task 的 Exception 屬性:

var testTask = TestAsync(5, -10);
testTask.ContinueWith(task => {
   if (task.IsFaulted) {
      Console.WriteLine(task.Exception.GetBaseException());
   }
   else {
      Console.WriteLine(task.Result);
   }
});

在 .Net 4.0 、 Sliverlight 5.0 、以及 MonoTouch 中均有類似的問題, 因此, 必須小心翼翼的處理 Task 產生的異常, 否則將會導致你的程序異常退出。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM