Как отменить и поднять исключение в Task.WhenAll, если возникло какое-либо исключение?

Question

Я жду многократную задачу, используя Task.WhenAll. Когда один из них генерирует исключение, мне бы хотелось, чтобы Task.WhenAll (или любой другой способ ожидания задач с множественным числом) немедленно отменил другие задачи и вызвал исключение.

Возможно ли это?

Заранее спасибо

Answer 1

Cancellation is coopertiveWhenAll не может отменить темы, но вы можете передать их все в CancellationToken и огонь маркер, когда вы получите исключение.

CancellationTokenSource cts = new CancellationTokenSource(); 

var task1 = Func1Async(cts.Token); 
task1.ContinueWith(task => cts.Cancel(), cts.Token, TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 
var task2 = Func2Async(cts.Token); 
task2.ContinueWith(task => cts.Cancel(), cts.Token, TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 
var task3 = Func3Async(cts.Token); 
task3.ContinueWith(task => cts.Cancel(), cts.Token, TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 

await Task.WhenAll(task1, task2, task3); 

внутри методов, которые вы должны поставить token.ThrowIfCancellationRequested() внутри функции, чтобы проверить маркер и отменить задание

public async Task Func1Async(CancellationToken token) 
{ 
    foreach(var item in GetItems1()) 
    { 
     await item.ProcessAsync(token); 
     token.ThrowIfCancellationRequested(); 
    } 
} 

---

ПРИМЕЧАНИЕ: Вы можете очистит код немного, сделав метод расширения

public static class ExtensionMethods 
{ 
    public Task CancelOnFaulted(this Task task, CancellationTokenSource cts) 
    { 
     task.ContinueWith(task => cts.Cancel(), cts.Token, taskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 
     return task; 
    } 

    public Task<T> CancelOnFaulted<T>(this Task<T> task, CancellationTokenSource cts) 
    { 
     task.ContinueWith(task => cts.Cancel(), cts.Token, taskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 
     return task; 
    } 
} 

Это сделало бы код выглядеть

CancellationTokenSource cts = new CancellationTokenSource(); 

var task1 = Func1Async(cts.Token).CancelOnFaulted(cts); 
var task2 = Func2Async(cts.Token).CancelOnFaulted(cts); 
var task3 = Func3Async(cts.Token).CancelOnFaulted(cts); 

await Task.WhenAll(task1, task2, task3);