快捷導(dǎo)航

C#多線程中的異常處理操作示例

更新時(shí)間：2019年05月06日 11:27:14 作者：行走即歌

這篇文章主要介紹了C#多線程中的異常處理操作,涉及C#多線程及異常的捕獲、處理等相關(guān)操作技巧,需要的朋友可以參考下

本文實(shí)例講述了C#多線程中的異常處理操作。分享給大家供大家參考，具體如下：

常規(guī)Thread中處理異常

使用Thread創(chuàng)建的子線程,需要在委托中捕捉,無(wú)法在上下文線程中捕捉

static void Main(string[] args)
{
  ThreadStart threadStart = DoWork;
  Thread thread = new Thread(threadStart);
  thread.Start();
  thread.Join();
}
static void DoWork()
{
  try
  {
    throw new Exception("子線程出現(xiàn)異常了");
  }
  catch (Exception ex)
  {
    Trace.Assert(false, "Catch In Delegate");
  }
}

Task中處理異常

1.仍然可以在委托中捕獲異常

2.可以捕獲Task.Wait() 或者 Task.Result 的 AggregateException 異常

try
{
  task.Wait();
}
catch (AggregateException ex)
{
  Console.WriteLine($"Error: {ex.GetType().Name}");
  foreach (Exception item in ex.InnerExceptions)
  {
    Console.WriteLine($"{item.GetType().Name}, {item.Message}");
  }
}

AggregateException 是并行任務(wù)中捕獲的一組異常

通過(guò)延續(xù)任務(wù)捕獲前驅(qū)任務(wù)中的異常

static void Main(string[] args)
{
  Task task = Task.Run(() => throw new Exception("前驅(qū)任務(wù)異常了"));
  Task faultedTask = task.ContinueWith(antecedentTask =>
  {
    antecedentTask.Exception.Handle(eachE =>
    {
      Console.WriteLine($"Error: {eachE.Message}");
      return true;
    });
  },TaskContinuationOptions.OnlyOnFaulted);
  faultedTask.Wait();
}

前驅(qū)任務(wù):使用Run書(shū)寫(xiě)的第一個(gè)任務(wù)就是前驅(qū)任務(wù)

延續(xù)任務(wù):在一個(gè)任務(wù)后使用ContinueWith添加的任務(wù)就是延續(xù)任務(wù),延續(xù)一般是一個(gè)全新的工作線程

TaskContinuationOptions:指定延續(xù)任務(wù)時(shí)的可配置項(xiàng),默認(rèn)情況下前驅(qū)任務(wù)完成后,立即執(zhí)行延續(xù)任務(wù),OnlyOnFaulted表示只有前驅(qū)任務(wù)失敗(出異常的時(shí)候)才會(huì)執(zhí)行這一個(gè)延續(xù)任務(wù)

Task.Exception也是一個(gè)AggregateException 異常

注意:

1.當(dāng)指定的TaskContinuationOptions與前驅(qū)任務(wù)運(yùn)行結(jié)果不一致時(shí),強(qiáng)制調(diào)用延續(xù)任務(wù)Wait()會(huì)引發(fā)TaskCanceledException異常

static void Main(string[] args)
{
  Task task = new Task(() =>
  {
    Console.WriteLine("前驅(qū)動(dòng)任務(wù)執(zhí)行中...");
  });
  Task faultedTask = task.ContinueWith(antecedentTask =>
  {
    Console.WriteLine("延續(xù)動(dòng)任務(wù)執(zhí)行中...");
  }, TaskContinuationOptions.OnlyOnFaulted);
  task.Start();
  try
  {
    faultedTask.Wait();
  }
  catch (AggregateException ex)
  {
    Console.WriteLine($"Error: {ex.GetType().Name}");
    foreach (Exception item in ex.InnerExceptions)
    {
      Console.WriteLine($"{item.GetType().Name}, {item.Message}");
    }
  }
  Console.WriteLine($"前驅(qū)任務(wù)狀態(tài){task.Status}");
  Console.WriteLine($"延續(xù)任務(wù)狀態(tài){faultedTask.Status}");
}

Ctrl+F5 輸出

補(bǔ)充:

假如在前驅(qū)任務(wù)中出現(xiàn)了異常,如OnlyOnFaulted所愿,會(huì)執(zhí)行faultedTask任務(wù),并且在faultedTask.Wait()中不會(huì)捕捉到前驅(qū)任務(wù)的異常,具體看下面一點(diǎn)

2.延續(xù)任務(wù)雖然在異步任務(wù)中提供了類似if else 的ContinueWith但是在異常處理上還是有點(diǎn)局限,看一個(gè)例子

static void Main(string[] args)
{
  Task task = Task.Run(()
    =>
  throw new Exception("前驅(qū)任務(wù)異常了"));
  Task task1 = task.ContinueWith(antecedentTask =>
  {
    throw new Exception("延續(xù)任務(wù)1異常了");
  });
  Task task2 = task1.ContinueWith(antecedentTask =>
  {
    throw new Exception("延續(xù)任務(wù)2異常了");
  });
  Task task3 = task2.ContinueWith(antecedentTask =>
  {
    throw new Exception("延續(xù)任務(wù)3異常了");
  });
  try
  {
    task3.Wait();
  }
  catch (AggregateException ex)
  {
    Console.WriteLine($"Error: {ex.GetType().Name}");
    foreach (Exception item in ex.InnerExceptions)
    {
      Console.WriteLine($"{item.GetType().Name}, {item.Message}");
    }
  }
}

Ctrl+F5 輸出

其實(shí)這樣也可以理解,task3.Wait()只會(huì)收集task3所在工作線程上的異常,遺憾的是Task.Exception.InnerExceptions是一個(gè)只讀集合,這樣一來(lái),每個(gè)任務(wù)的異常只能在各自委托中處理了,事實(shí)上也應(yīng)該如此,可以使用TaskContinuationOptions進(jìn)行靈活控制

使用CancellationTokenSource取消任務(wù)

static void Main(string[] args)
{
  CancellationTokenSource cancellationTokenSource = new CancellationTokenSource();
  cancellationTokenSource.Token.Register(() => 
  {
    Console.WriteLine("任務(wù)取消了");
  });
  cancellationTokenSource.CancelAfter(2000);
  Task task = Task.Run(() =>
  {
    while (true && !cancellationTokenSource.IsCancellationRequested)
    {
      Console.WriteLine("任務(wù)執(zhí)行中...");
      Thread.Sleep(300); 
    }
  },
  cancellationTokenSource.Token);
  task.Wait();
  Console.WriteLine($"任務(wù)的最終狀態(tài)是:{task.Status}");
}

Ctrl+F5 輸出