c# - 如何观察由于 C# 中另一个等待任务失败而未等待的任务?
问题描述
我有这个代码:
var task1 = operation1();
var task2 = operation2();
var result1 = await task1;
var result2 = await task2;
我也处理UnobservedTaskException
(通过记录它)。我面临的问题是,在 task1 失败并且第一次 await 导致异常后,task2 在错误中完成,然后我有一个我不想看到的日志条目,因为我已经记录了第一个异常,并且在那时所有后续我对例外不感兴趣。
所以我想知道是否有办法做某事,以便在我遇到异常后以某种方式“忽略”所有任务。
我知道我可以使用await Task.WhenAll
,但缺点是我必须等待所有异常发生,尽管我确定在第一个任务导致异常之后,我不需要等待其他任务整体完成操作已经失败。
另一种可能的解决方案是编写 try/catch 并取消所有任务,但这有点麻烦。
PS这个例子被简化了,我确实有多个任务像这样运行。所以我正在寻找一种适用于任意数量任务的通用解决方案
解决方案
作为替代方案,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();
}
推荐阅读
- r - 迭代地从数据框中提取一个值 (R)
- data-structures - 如何以一种简单而难忘的方式记住有序遍历和前序遍历?
- javascript - 预计角服务 1-2
- php - 带有自定义文本的 WooCommerce woocommerce_review_order_after_cart_contents 钩子
- scala - Spark Streaming 和 Kafka 集成中的并行任务数
- java - PHP 哈希密码与 Java 哈希兼容
- python - python - 如何在另一个字典中制作一个字典,在另一个字典中创建一个字典
- html - 当上面的课程打开时,联系我们消失
- python-3.x - 如果使用 python 不存在字符串,如何忽略文件?
- android - RangeError(索引):无效值:不在包含范围内 0..13:14 Flutter