如何并行执行多数据库查询并合并结果？异步问题排查

问题根源分析 #

1. 同步查询阻塞：使用ToList()时，查询会同步阻塞当前线程，调用方法时就会立即执行完整查询，导致三个任务串行执行，Task.WhenAll只是等待已完成的任务。
2. DbContext线程安全限制：即使改用ToListAsync()，如果三个查询共用同一个DbContext实例，EF Core会强制串行执行所有操作（因为DbContext不是线程安全的，内部有同步机制），这是改异步后仍未实现并行的核心原因。
3. 异步方法实现错误：如果方法未标记async、未用await调用ToListAsync()，或误用.Result/.Wait()，会导致异步方法退化为同步执行。

正确实现步骤 #

1. 重构查询方法为异步+独立DbContext

确保每个查询方法使用独立的DbContext，并真正异步执行：

// 示例：入库记录查询方法
private async Task<List<StockTransaction>> GetStockInTransactionsAsync(IServiceProvider serviceProvider)
{
    // 创建作用域获取独立DbContext（依赖注入场景）
    using var scope = serviceProvider.CreateScope();
    var dbContext = scope.ServiceProvider.GetRequiredService<YourDbContext>();

    return await dbContext.StockIn
        .Select(stockIn => new StockTransaction
        {
            TransactionId = stockIn.Id,
            Type = StockTransactionType.In,
            Quantity = stockIn.Quantity,
            // 映射其他必要字段
        })
        .ToListAsync();
}

// 同理实现出库、调整记录的异步查询方法
private async Task<List<StockTransaction>> GetStockOutTransactionsAsync(IServiceProvider serviceProvider)
{
    using var scope = serviceProvider.CreateScope();
    var dbContext = scope.ServiceProvider.GetRequiredService<YourDbContext>();

    return await dbContext.StockOut
        .Select(stockOut => new StockTransaction
        {
            TransactionId = stockOut.Id,
            Type = StockTransactionType.Out,
            Quantity = stockOut.Quantity,
            // 映射其他必要字段
        })
        .ToListAsync();
}

private async Task<List<StockTransaction>> GetStockAdjustTransactionsAsync(IServiceProvider serviceProvider)
{
    using var scope = serviceProvider.CreateScope();
    var dbContext = scope.ServiceProvider.GetRequiredService<YourDbContext>();

    return await dbContext.StockAdjust
        .Select(adjust => new StockTransaction
        {
            TransactionId = adjust.Id,
            Type = StockTransactionType.Adjust,
            Quantity = adjust.Quantity,
            // 映射其他必要字段
        })
        .ToListAsync();
}

2. 并行执行并合并结果

启动所有异步任务后等待全部完成，再合并结果：

// 假设在异步方法内执行，且已注入IServiceProvider
var stockInTask = GetStockInTransactionsAsync(_serviceProvider);
var stockOutTask = GetStockOutTransactionsAsync(_serviceProvider);
var stockAdjustTask = GetStockAdjustTransactionsAsync(_serviceProvider);

// 等待所有异步查询完成
await Task.WhenAll(stockInTask, stockOutTask, stockAdjustTask);

// 合并所有结果
var allTransactions = stockInTask.Result
    .Concat(stockOutTask.Result)
    .Concat(stockAdjustTask.Result)
    .ToList();

// 后续业务逻辑

关键注意事项 #

• DbContext独立性：必须为每个异步查询分配独立的DbContext，否则EF Core会强制串行执行，无法实现真正并行。
• 避免同步阻塞：绝对不要在异步方法内使用.Result或.Wait()，这会导致线程阻塞，破坏异步并行逻辑。
• 异步方法规范：所有异步方法需标记async，返回Task/Task<T>，且内部用await处理异步操作。

内容的提问来源于stack exchange，提问作者Bastien Vandamme