在 IEnumerable.Select 中调用异步方法

Question

我有以下代码，使用异步方法在 R 和 L 类型之间转换项目：

class MyClass<R,L> {

    public async Task<bool> MyMethodAsync(List<R> remoteItems) {
        ...

        List<L> mappedItems = new List<L>();
        foreach (var remoteItem  in remoteItems )
        {
            mappedItems.Add(await MapToLocalObject(remoteItem));
        }

        //Do stuff with mapped items

        ...
    }

    private async Task<L> MapToLocalObject(R remoteObject);
}

这是否可以使用 IEnumerable.Select 调用（或类似调用）来减少代码行数？我试过这个：

class MyClass<R,L> {

    public async Task<bool> MyMethodAsync(List<R> remoteItems) {
        ...

        List<L> mappedItems = remoteItems.Select<R, L>(async r => await MapToLocalObject(r)).ToList<L>();

        //Do stuff with mapped items

        ...
    }
}

但我得到错误：

"无法将异步 lambda 表达式转换为委托类型 'System.Func<R,int,L>'。异步 lambda 表达式可能返回 void， Task 或 Task<T>，它们都不能转换为 'System.Func<R,int,L>'。”

我相信我遗漏了关于 async/await 关键字的一些内容，但我不知道是什么。有没有人知道我可以如何修改我的代码以使其正常工作？

Answer 1

您可以通过考虑游戏中的类型来解决这个问题。例如，MapToLocalObject - 当被视为异步函数时 - 确实从 R 映射到 L。但是如果你把它看成一个同步函数，它会从R映射到Task<L>。

Task 是一个“未来”，因此 Task<L> 可以被认为是一种类型， 在未来的某个时间点会产生一个L。

因此您可以轻松地将R 序列转换为Task<L> 序列：

IEnumerable<Task<L>> mappingTasks = remoteItems.Select(remoteItem => MapToLocalObject(remoteItem));

请注意，此代码与您的原始代码之间存在重要的语义差异。您的原始代码等待每个对象被映射，然后再继续下一个对象；此代码将同时启动所有映射。

您的结果是一系列任务 - 一系列未来的L 结果。要处理任务序列，有一些常见的操作。 Task.WhenAll 和 Task.WhenAny 是针对最常见需求的内置操作。如果您想等到所有映射都完成，您可以这样做：

L[] mappedItems = await Task.WhenAll(mappingTasks);

如果您希望在完成每个项目时对其进行处理，您可以使用来自my AsyncEx library 的OrderByCompletion：

Task<L>[] orderedMappingTasks = mappingTasks.OrderByCompletion();
foreach (var task in orderedMappingTasks)
{
  var mappedItem = await task;
  ...
}