Task.WaitAll引發OperationCanceledException

Question

我有一個運行任務清單，其編號爲CancellationTokenSource。

我希望當前線程一直等到所有任務完成或，直到任務被取消。

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

即使當前線程處於等待狀態，任務可能會被另一個任務取消。這是正常的行爲。

但是，噹噹前線程處於等待狀態並且另一個任務取消任務時，WaitAll會向CancellationTokenSource拋出一條消息：「操作已取消。」。

我知道它被取消了，我故意這樣做了。我只是希望它在任務被取消或完成後繼續執行下一個代碼，而不會引發異常。

我知道我可以用try & catch來包裝這段代碼，但拋出一個異常很繁重，我不希望它發生在像這樣的正常行爲上。

Answer 1

這種阻塞機制可以表述爲：

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

這給你一個任務回來，我們可以等待，但也可以從管理取消。所以，忽略消除異常，可以進行以下操作：

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); 
    } 
} 

這將讓你沒有遇到一個OperationCancelledException寫以下，再次：

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(); 
    } 
} 

希望它hel PS。