如何在發生異常時中斷任務鏈？

Question

我創建了作品鏈。他們將在我的附加線程內工作。爲此我使用Task。另外，如果發生任何異常並將其放入調用線程中，我想要中斷鏈的工作。但我看到我的鏈條沒有損壞，並且act3的act2也完成了。

我該如何解決？

using System; 
using System.Threading.Tasks; 

namespace Bushman.Sandbox.Threads { 
    class Program { 
     static void Main(string[] args) { 
      Console.Title = "Custom thread"; 

      try { 
       // First work 
       Action act1 =() => { 
        for (int i = 0; i < 5; i++) { 

         // I throw the exeption here 
         if (i == 3) throw new Exception("Oops!!!"); 

         Console.WriteLine("Do first work"); 
        } 
       }; 

       // Second work 
       Action act2 =() => { 
        for (int i = 0; i < 5; i++) 
         Console.WriteLine(" Do second work"); 
       }; 

       // Third work 
       Func<int> act3 =() => { 
        for (int i = 0; i < 5; i++) 
         Console.WriteLine(" Do third work"); 
        return 12345; 
       }; 

       Task task = new Task(act1); 

       // Build the chain of the works 
       var awaiter = task.ContinueWith(_ => act2(), 
        TaskContinuationOptions.ExecuteSynchronously) 
        .ContinueWith(_ => act3(), 
        TaskContinuationOptions.ExecuteSynchronously) 
        .GetAwaiter(); 

       Console.WriteLine("Work started..."); 

       // launch the chain 
       task.Start(); 

       // Here I get some result 
       int result = awaiter.GetResult(); // 12345 

       if (task.IsCanceled || task.IsFaulted) { 
        throw task.Exception.InnerException; 
       } 

       Console.WriteLine("The result: {0}", 
        result.ToString()); 
      } 
      catch (Exception ex) { 
       Console.ForegroundColor = ConsoleColor.Red; 
       Console.WriteLine(ex.Message); 
       Console.ResetColor(); 
      } 

      Console.WriteLine("Press any key for exit..."); 
      Console.ReadKey(); 
     } 
    } 
} 

Answer 1

您必須使用NotOnFaulted任務延續選項。

由於TaskContinuationOptions裝飾有Flags屬性，因此可以將NotFaulted與其他選項結合使用。

var awaiter = task.ContinueWith(_ => act2(), 
       TaskContinuationOptions.ExecuteSynchronously | TaskContinuationOptions.NotOnFaulted) 
       .ContinueWith(_ => act3(), 
       TaskContinuationOptions.ExecuteSynchronously | TaskContinuationOptions.NotOnFaulted) 
       .GetAwaiter(); 

即使您正在使用異步/等待關鍵詞，這種方法仍然有效（但你擺脫GetAwaiter通話）

Answer 2

代碼試圖以一種非常規使用任務方式，就好像它們是線程一樣。他們不是 - 任務是一個將被安排在線程池線程上運行的工作，而不是線程本身。調用Task.Start將不會執行任何操作，它會將時間表其委託在一個線程上運行。這就是爲什麼從不使用構造函數創建任務的原因。

啓動和協調任務最簡單的方法是使用Task.Run和async/await，如：

public static async Task<int> MyMethodAsync() 
{ 
    try 
    { 
     await Task.Run(()=>act1()); 
     await Task.Run(()=>act2()); 
     var result=await Task.Run(()=>act3()); 
     return result; 
    } 
    catch (Exception exc) 
    { 
      //Do something 
    } 
} 

你不能在一個控制檯應用程序的主要功能使用async/await，所以你必須調用通過以下方式方法：

var result=MyMethodAsync().Result; 

上調用任務.Wait()或.Result重新拋出它裏面提出的任何異常。

沒有async/await，您需要使用ContinueWith並實際檢查上一個任務的結果。如果你只是想停下來處理，你可以通過TaskContinuationOptions.NotOnFaulted：

var result = Task.Run(()=>act1()) 
       .ContinueWith(t1=>act2(),TaskContinuationOptions.NotOnFaulted) 
       .ContinueWith(t2=>act3(),TaskContinuationOptions.NotOnFaulted) 
       .Result; 

你並不需要去的awaiter明確的訪問。最後一次撥打.Result將返回整數結果，如果以前的某個任務出現故障，則返回AggregateException