如何用异步Lambda结合LINQ的ToDictionary填充Dictionary<long, Data>？

这个问题我之前也碰到过，核心原因是ToDictionary本身是同步方法——它不会自动处理异步lambda返回的Task<Data>，所以直接用async lambda的话，字典里存的就是未完成的任务，而不是实际的Data结果。下面给你两种靠谱的解决方案：

方案一：并行处理（推荐，效率更高） #

这种方式会同时启动所有GetData异步请求，等全部完成后再构建字典，适合IO密集型场景（比如数据库查询、API调用）：

// 先获取去重后的实体（和你原来的逻辑一致）
var uniqueEntities = entities
    .GroupBy(e => e.EntityId)
    .Select(g => g.First())
    .ToList();

// 为每个实体启动异步任务，同时保留EntityId的关联
var tasks = uniqueEntities.Select(async entity => 
    new { entity.EntityId, Data = await GetData(entity) });

// 等待所有异步任务完成，拿到最终结果集合
var completedResults = await Task.WhenAll(tasks);

// 把结果转成目标字典
var myDictionary = completedResults.ToDictionary(r => r.EntityId, r => r.Data);

方案二：串行处理（适合需要顺序执行的场景） #

如果你的GetData调用有依赖关系，或者需要严格按顺序执行，可以用这种逐个等待的方式：

var uniqueEntities = entities
    .GroupBy(e => e.EntityId)
    .Select(g => g.First())
    .ToList();

// 先创建空字典
var myDictionary = new Dictionary<long, Data>();

foreach (var entity in uniqueEntities)
{
    // 等待当前实体的GetData完成后，再添加到字典
    var data = await GetData(entity);
    myDictionary.Add(entity.EntityId, data);
}

为什么原来的代码不行？ #

你原来的代码里，async entity => await GetData(entity)这个lambda返回的是Task<Data>，而ToDictionary作为同步方法，只会把这个Task直接当作值存入字典，不会帮你等待任务完成。所以最终得到的是Dictionary<long, Task<Data>>，而不是你想要的Dictionary<long, Data>。

内容的提问来源于stack exchange，提问作者michal.jakubeczy