优化 async/await - 在 forEach 中分配变量

Question

我知道在foreach 中使用await 由于性能原因并不是一个好的做法，因为它会按顺序等待每个任务。

foreach (var task in result)
{
     task.Stages = await GetStagesForTask(task.Id);
}

那么我该如何改进该代码呢？我试图做这样的事情：

List<Task> listOfTasks = new List<Task>();

foreach (var task in result)
{
    var stage = GetStagesForTask(task.Id);
    listOfTasks.Add(stage);
    task.Stages = stage;
}

await Task.WhenAll(listOfTasks);

但当然因为task.Stages = stage;这里的类型不正确，它不会起作用。

Answer 1

您可以将 LINQ 与异步委托一起使用：

var tasks = result.Select(async task =>
{
    var stage = await GetStagesForTask(task.Id);
    task.Stages = stage;
});

await Task.WhenAll(tasks);

或者引入一个局部函数：

List<Task> listOfTasks = new List<Task>();

async Task SetStagesAsync(YourTask task)
{
    task.Stages = await GetStagesForTask(task.Id);
}

foreach (var task in result)
{
    listOfTasks.Add(SetStagesAsync(task));
}

await Task.WhenAll(listOfTasks);

甚至是两者的结合：

async Task SetStagesAsync(YourTask task)
{
    task.Stages = await GetStagesForTask(task.Id);
}

await Task.WhenAll(result.Select(SetStagesAsync));

Answer 2

如果您不介意同时改变实体的 Stages 属性，Johnathan Barclay 的 solution 是完美的。但是，如果您希望将突变推迟到所有异步操作完成之前，那么您可以考虑将您的实体投影到Task<Action>s 的列表中，然后使用await 使用Task.WhenAll 执行这些任务，最后按顺序调用所有由此产生的Actions：

Task<Action>[] tasks = entities.Select(async entity =>
{
    var stages = await GetStagesForEntityAsync(entity.Id);
    return new Action(() => entity.Stages = stages);
}).ToArray();

Action[] actions = await Task.WhenAll(tasks);

foreach (var action in actions) action.Invoke();

在上面的示例中，我已将示例中的 task 和 result 变量重命名为 entity/entities，以防止实体与内置 Task 类之间出现任何混淆。

LINQ Select 运算符可以轻松地将一个可枚举对象投影到另一个对象，当您想要从对象列表创建自定义任务列表时，它尤其方便。

Answer 3

解决此问题的一种巧妙方法是为每个任务创建一个线程，await 将发生在单独的线程内。因此，您将在foreach 中创建线程，它们将在单独的线程中执行等待，然后另一个foreach 将为每个线程调用.Join()。通过这种方式，您不会有顺序等待，而是创建线程，它们将并行工作，您将等待最长的任务，而不是所有任务所需时间的总和。

但是，如果您有很多任务，请注意耗尽所有资源。如果你有很多任务，那么将它们分成大概 10 个线程的块并应用我上面描述的方法。