例外が発生したときにタスクチェーンを壊す方法はありますか？

Question

私は作品のチェーンを作成します。彼らは私の追加のスレッドの内部で作業する必要があります。私はこの目的のためにTaskを使用します。また、例外が発生した場合にチェーンの作業を中断し、呼び出しスレッドにスローしたいと思います。しかし、チェーンが壊れていないことがわかりました。act2とact3も完成しました。

どうすれば修正できますか？あなたはNotOnFaultedタスク継続オプションを使用する必要が

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

。

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への最後の呼び出しは、整数結果を返すか、以前のタスクの1つが失敗した場合にはAggregateExceptionを投げるでしょう。