如何解决如何观察由于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();
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。