使用Task.WhenAll执行多数据库查询未达并发效果问题排查

核心现象 #

用Task.WhenAll并行执行10次数据库查询，单条查询耗时100ms，但10条总耗时达1000ms（与串行一致）。已确认所有任务均在首个任务完成前启动，且因每条查询需结合entryId+language+version+secondaryId1等唯一组合筛选，无法合并为单条批量查询。

可能原因 #

1. 数据库连接池限制 #

数据库连接池默认限制同时可用连接数（如SQL Server默认Max Pool Size=100，若连接字符串被修改为更小值，或连接未及时释放），会导致并行任务排队等待连接，实际串行执行。

2. 缺失复合索引导致查询性能瓶颈 #

每条查询的多字段筛选组合没有对应的复合索引，单条查询本身耗时较高，且数据库CPU/IO资源被单条查询占满，无法同时处理多个并行请求。

3. 数据库实例并发配置限制 #

数据库实例的最大并发连接数、CPU核心数等配置不足，超出限制的查询只能排队等待执行。

解决办法 #

1. 调整连接池配置并确保连接释放 #

• 修改数据库连接字符串，设置足够大的Max Pool Size（根据服务器承载能力调整，例如设为50）：

  Server=你的服务器地址;Database=你的数据库名;User Id=账号;Password=密码;Max Pool Size=50;
  

• 确保DbContext/工作单元被及时释放，用using包裹避免连接泄漏：

  public virtual async Task<Entry> GetEntryAsync(long entryId) 
  { 
      using var unitOfWork = this.unitOfWorkFactory.Create();
      var entryRepo = unitOfWork.GetWordsRepository(language);
      return await entryRepo.GetEntryAsync(entryId);
  }
  

2. 添加复合索引优化单条查询 #

针对查询的筛选组合创建复合索引，大幅降低单条查询耗时，让数据库能高效处理并行请求：

CREATE NONCLUSTERED INDEX IX_Entries_FilterCombination
ON Entries (entryId, language, version, secondaryId1)
INCLUDE (Id); -- 包含查询需要返回的字段，避免额外的键查找

3. 验证数据库并行执行状态 #

用数据库监控工具（如SQL Server Profiler、pg_stat_activity）跟踪查询执行：

• 若查询排队执行：调整连接池或数据库实例的并发配置；
• 若查询同时执行但总耗时仍高：进一步优化单条查询（如简化查询逻辑、调整索引）。

内容的提问来源于stack exchange，提问作者Dylan Cross