最初的方法是低效的foreach循环,等待每个作业(job)(这是一个I/O绑定的网络调用):

foreach (var job in Jobs)
{
    try
    {
        await DoJobAsync(job); //Pass job to external vendor API
        job.Succeeded = true;
    }
    
    catch (Exception)
    {
        //do nothing, let loop continue
    }
}

现在为了提高性能,我希望使用Task.WhenAll以非阻塞方式处理所有作业(job).

但是,如果DoJobAsync任务没有引发异常,我们需要确保每个job对象只有Succeeded属性设置为true.

如果我们这样做:

await Task.WhenAll(Jobs.Select(j =>
{
    var task = DoJobAsync(j);
    j.Succeeded = true;
    return task;
}));

我的理解是,如果任何作业(job)任务最终抛出异常,该属性仍将切换为true,因 for each 单独的任务在创建时都不会等待,从而使代码流直接经过它.

我知道我可以捕获Task.WhenAll返回的Task,以访问抛出的所有异常的列表,但我无法找到使用它们追溯到抛出异常的job的方法.

我如何解决这个问题?

推荐答案

您可以使用异步委托作为Select运算符的selector:

await Task.WhenAll(Jobs.Select(async job =>
{
    await DoJobAsync(job);
    job.Succeeded = true;
}));

这样,每个作业(job)将被投影到Task,而不是原始的DoJobAsync(job)任务,而是封装更新Succeeded属性的逻辑的包装器任务.此属性将在DoJobAsync(job)任务成功完成后立即更新.

多个Job对象可能会并行更新其Succeeded属性.这取决于当前线程上是否安装了SynchronizationContext.

.net相关问答推荐

.NET MAUI垂直扫描视图(tiktok幻灯片等)

将多行参数传递给Power Shell中的DotNet Pack命令

无法在Ubuntu 22.04.3上运行带有Rider 2023和DotNet-8.0的项目

Azure Function应用程序-如何升级.NET运行时

EFCore.DbSet.Update 方法添加新行而不是更新它

为什么这个同步运行的异步睡眠会挂起?

是否有任何为 C# 编写的模糊搜索或字符串相似函数库?

为什么 Any() 不适用于 c# null 对象

为什么我得到 411 Length required 错误?

OpenCV的.Net(dotNet)包装器?

使文本框不可编辑

处理序列没有元素异常

什么是 project.lock.json?

如何结合 ||条件语句中的运算符

从 List 到数组 T[] 的转换

修剪数组中的所有字符串

双倍的? = 双倍? + 双倍?

C#中的引用类型

微软内部 PriorityQueue 中的错误?

如何重新启动 WPF 应用程序?