Task.WaitAllはOperationCanceledExceptionをスローします

Question

私は同じCancellationTokenSourceで実行中のタスクのリストを持っています。

タスクがキャンセルされるまで、すべてのタスクが完了するまで現在のスレッドがまたはになるまで待ちます。

Task.WaitAll(tasks.ToArray(), searchCencellationTokenSource.Token); 
System.Console.WriteLine("Done !"); 

現在のスレッドが待機状態であっても、別のタスクによってタスクがキャンセルされることがあります。これは正常な動作です。

ただし、現在のスレッドが待機状態で、別のタスクがタスクをキャンセルしている間に、WaitAllはCancellationTokenSourceに「この操作はキャンセルされました」というメッセージをスローします。

私はそれがキャンセルされたことを知っています、私は意図的にそれをしました。例外がスローされることなく、タスクがキャンセルまたは完了した後、次のコードに進むことができます。

私はこのコードをtry & catchでラップすることができますが、例外をスローすることは重い操作であり、このような通常の動作では発生したくありません。これはあなたに私たちが待つことができますが、またの取り消しを管理することができ、タスクバックを与える

Task.WhenAll(taskA, taskB, taskC).Wait() 

：

Answer 1

このブロック機構は、と言い換えることができます。

OperationCancelledExceptionをスローしません

Task.WhenAll(taskA, taskB, taskC).ContinueWith(t => { }, TaskContinuationOptions.OnlyOnCanceled).Wait(); 

：だから、キャンセル例外を無視して、次の操作を行うことができます。

次のようにこれは、その後、拡張メソッドにラップすることができます

あなたが OperationCancelledExceptionに遭遇することなく、再び、次のように書くことができるようになる

public static class TaskExtensions 
{ 
    public static Task IgnoreCancellation(this Task task) 
    { 
     return task.ContinueWith(t => { }, TaskContinuationOptions.OnlyOnCanceled); 
    } 
} 

を：

Task.WhenAll(taskA, taskB, taskC).IgnoreCancellation().Wait(); 

は、ここで示すテスト・フィクスチャですアプローチの仕組み：

public class IgnoreTaskCancellation 
{ 
    [Fact] 
    public void ShouldThrowAnAggregateException() 
    { 
     CancellationTokenSource cts = new CancellationTokenSource(10); 

     Task taskA = Task.Delay(20, cts.Token); 
     Task taskB = Task.Delay(20, cts.Token); 
     Task taskC = Task.Delay(20, cts.Token); 

     Assert.Throws<AggregateException>(() => Task.WhenAll(taskA, taskB, taskC).Wait()); 
    } 

    [Fact] 
    public void ShouldNotThrowAnException() 
    { 
     CancellationTokenSource cts = new CancellationTokenSource(10); 

     Task taskA = Task.Delay(20, cts.Token); 
     Task taskB = Task.Delay(20, cts.Token); 
     Task taskC = Task.Delay(20, cts.Token); 

     Task.WhenAll(taskA, taskB, taskC).ContinueWith(t => { }, TaskContinuationOptions.OnlyOnCanceled).Wait(); 
    } 

    [Fact] 
    public void ShouldNotThrowAnExceptionUsingIgnore() 
    { 
     CancellationTokenSource cts = new CancellationTokenSource(10); 

     Task taskA = Task.Delay(20, cts.Token); 
     Task taskB = Task.Delay(20, cts.Token); 
     Task taskC = Task.Delay(20, cts.Token); 

     Task.WhenAll(taskA, taskB, taskC).IgnoreCancellation().Wait(); 
    } 
} 

ps。