如何观察由于C＃中另一个等待的任务失败而导致未等待的任务？ 每个累进异步的基本实现样品用量

问题描述

我有此代码：

var task1 = operation1();
var task2 = operation2();


var result1 = await task1;
var result2 = await task2;

我也处理UnobservedTaskException（通过记录）。我面临的问题是，在task1失败并首先等待导致异常之后，task2完成一个错误，然后我不想看到一个日志条目，因为我已经记录了第一个异常，并且在那时所有后续例外对我来说并不重要。

所以我想知道是否有办法做某件事，以便在遇到异常后以某种方式“忽略”所有任务。

我知道我可以使用await Task.WhenAll，但是缺点是我必须等待所有异常发生，尽管我确定在第一个任务导致异常之后，我不需要等待其他任务要完成，因为整个操作已经失败。

另一种可能的解决方案是编写try / catch并取消所有任务，但这有点麻烦。

P.S。 该示例已简化，我确实有多个任务正在运行。因此，我正在寻找一种适用于任何数量任务的通用解决方案

解决方法

作为Task.WhenAll的替代方法，您可以对Task.WhenAny使用渐进方法。

任何一项任务完成后，您可以检查结果，然后决定下一步要做什么。 （请记住，Task.WhenAny即使等待也不会引发异常）。这种方法的优点在于，您可以轻松地对此进行限制（控制并行度）。

每个累进异步的基本实现

static async Task ProgressiveAsyncForEach(int degreeOfParallelism,params Task[] tasks)
{
    var toBeProcessedTasks = new HashSet<Task>();
    var remainingTasksEnumerator = tasks.GetEnumerator();

    void AddNextTask()
    {
        if (!remainingTasksEnumerator.MoveNext()) return;
        var nextTaskToProcess = (Task)remainingTasksEnumerator.Current;
        toBeProcessedTasks.Add(nextTaskToProcess);
    }

    //Initialize
    while (toBeProcessedTasks.Count < degreeOfParallelism)
    {
        AddNextTask();
    }

    while (toBeProcessedTasks.Count > 0)
    {
        var processedTask = await Task.WhenAny(toBeProcessedTasks).ConfigureAwait(false);
        if (!processedTask.IsCompletedSuccessfully)
        {
            Console.WriteLine("One of the task has failed");
            //TODO: log first failed task
            //CONSIDER: cancel all the remaining tasks
            return;
        }

        toBeProcessedTasks.Remove(processedTask);
        AddNextTask();
    }
}

样品用量

static async Task Main(string[] args)
{
    await ProgressiveAsyncForEach(2,Faulty(),Fast(),Slow());
    Console.WriteLine("Application finished");
}

static async Task Slow()
{
    Console.WriteLine("Slow started");
    await Task.Delay(1000);
    Console.WriteLine("Slow finished");
}

static async Task Fast()
{
    Console.WriteLine("Fast started");
    await Task.Delay(500);
    Console.WriteLine("Fast finished");
}

static async Task Faulty()
{
    Console.WriteLine("Faulty started");
    await Task.Delay(700);
    throw new Exception();
}