c# - 从任务中引发聚合异常不会破坏所有其他任务

Question

我有两个任务：

try
{
    List<Task> tasks = new List<Task>();

    Task task1 = Task.Factory.StartNew(() => func(param));
    tasks.Add(task1);
    if (someCondition)
    {
        Task task2 = Task.Factory.StartNew(() => func2(param2));
        tasks.Add(task2);
     }

     tasksArr = tasks.ToArray();

     Task.WaitAll(tasksArr);
 }
 catch (AggregateException e)
 {
     //handle
 }
 catch (Exception)
 {
     //handle
 }

如果其中一个任务发生异常，我将抛出一个新的聚合异常，但只有在第二个任务完成后才到达 catch 语句。我想立即抓住它，以停止第二个任务中不必要的工作。

我尝试使用取消令牌：

CancellationTokenSource cts = new CancellationTokenSource();

Task.WaitAll(tasksArr,cts.Token);

但这不是一个好的解决方案，因为它需要处理内部异常 + 捕获的异常将是OperationCanceledException

有任何想法吗？

Answer 1

要取消等待，需要将CancellationTokenSource类的实例传递给Task.WaitAll Method (Task[], CancellationToken)。此外，在任务失败（故障，即）时对运行的每个任务使用延续。TaskStatus.Faulted

var cancellationTokenSource = new CancellationTokenSource();

var tasks = new List<Task>();

var firstTask = new Task(FirstMethod);
firstTask.ContinueWith(t =>
    {
        Console.WriteLine("First task exception: {0}", t.Exception);
        cancellationTokenSource.Cancel();
    }, CancellationToken.None, TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default);
tasks.Add(firstTask);
firstTask.Start();

var secondTask = new Task(SecondMethod);
secondTask.ContinueWith(t =>
    {
        Console.WriteLine("Second task exception: {0}", t.Exception);
        cancellationTokenSource.Cancel();
    }, CancellationToken.None, TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default);
tasks.Add(secondTask);
secondTask.Start();

try
{
    var cancellationToken = cancellationTokenSource.Token;
    var tasksArray = tasks.ToArray();
    Task.WaitAll(tasksArray, cancellationToken);
}
catch (Exception e)
{
    // ...
}