Task的在主线程处理异常信息的Helper类

  1 using System;
  2 using System.Threading;
  3 using System.Threading.Tasks;
  4 
  5 namespace Xyfy.Helper
  6 {
  7     /// <summary>
  8     /// 
  9     /// </summary>
 10     public class TaskHelper
 11     {
 12         /// <summary>
 13         /// 
 14         /// </summary>
 15         event EventHandler<AggregateExceptionArgs> AggregateExceptionCatched;
 16 
 17         private readonly TaskFactory factory;
 18 
 19         private readonly Action<Exception> logAction;
 20 
 21         /// <summary>
 22         /// 
 23         /// </summary>
 24         /// <param name="errorLogAction"></param>
 25         public TaskHelper(Action<Exception> errorLogAction = null)
 26         {
 27             logAction = errorLogAction ?? Console.WriteLine;
 28             AggregateExceptionCatched += new EventHandler<AggregateExceptionArgs>(Program_AggregateExceptionCatched);
 29             factory = Task.Factory;
 30         }
 31 
 32         /// <summary>
 33         /// 
 34         /// </summary>
 35         /// <param name="workAction"></param>
 36         /// <returns></returns>
 37         public Task StartNew(Action workAction)
 38         {
 39             return ContinueWith(factory.StartNew(workAction));
 40         }
 41         /// <summary>
 42         /// 
 43         /// </summary>
 44         /// <param name="task"></param>
 45         /// <returns></returns>
 46         private Task ContinueWith(Task task)
 47         {
 48             return task.ContinueWith(t =>
 49             {
 50                 if (t.Exception != null)
 51                 {
 52                     AggregateExceptionArgs errArgs = new AggregateExceptionArgs()
 53                     {
 54                         AggregateException = new AggregateException(t.Exception.InnerExceptions)
 55                     };
 56                     AggregateExceptionCatched(null, errArgs);
 57                 }
 58             }, TaskContinuationOptions.OnlyOnFaulted);
 59         }
 60         /// <summary>
 61         /// 
 62         /// </summary>
 63         /// <param name="action"></param>
 64         /// <param name="cancellationToken"></param>
 65         /// <returns></returns>
 66         public Task StartNew(Action action, CancellationToken cancellationToken)
 67         {
 68             return ContinueWith(factory.StartNew(action, cancellationToken));
 69         }
 70         /// <summary>
 71         /// 
 72         /// </summary>
 73         /// <param name="action"></param>
 74         /// <param name="creationOptions"></param>
 75         /// <returns></returns>
 76         public Task StartNew(Action action, TaskCreationOptions creationOptions)
 77         {
 78             return ContinueWith(factory.StartNew(action, creationOptions));
 79         }
 80         /// <summary>
 81         /// 
 82         /// </summary>
 83         /// <param name="action"></param>
 84         /// <param name="cancellationToken"></param>
 85         /// <param name="creationOptions"></param>
 86         /// <param name="scheduler"></param>
 87         /// <returns></returns>
 88         public Task StartNew(Action action, CancellationToken cancellationToken,
 89             TaskCreationOptions creationOptions, TaskScheduler scheduler)
 90         {
 91             return ContinueWith(factory.StartNew(action, cancellationToken, creationOptions, scheduler));
 92         }
 93         /// <summary>
 94         /// 
 95         /// </summary>
 96         /// <param name="sender"></param>
 97         /// <param name="e"></param>
 98         private void Program_AggregateExceptionCatched(object sender, AggregateExceptionArgs e)
 99         {
100             foreach (Exception item in e.AggregateException.InnerExceptions)
101             {
102                 logAction(item);
103             }
104         }
105 
106     }
107 }