循环中Async数据库调用为何顺序执行？求问题排查方向

核心问题1：循环内的await导致顺序执行 #

你在循环里每次调用await dB.GetDataByNameAsync(...)时，await会暂停当前循环迭代，直到当前异步任务完全完成后才会进入下一次循环。这是await的预期行为——它确保代码按顺序执行，所以看起来和同步调用效果一致，但实际上每次数据库调用本身是异步的，只是被逐个等待了。

核心问题2：SqlConnection.Open()是同步阻塞调用 #

sql.Open()是同步方法，会阻塞当前线程直到数据库连接建立完成，这部分没有利用异步IO的优势，拖慢了整体执行效率。

修复方案 #

1. 实现并行异步调用（如果需要同时执行） #

若要让10次数据库调用并行执行，不要在循环内逐个await，而是先创建所有任务，再统一等待全部完成：

private static async Task ParallelDBCallAsync()
{
    DBLayer dB = new DBLayer();
    var tasks = new List<Task<Product>>();
    
    for (int i = 0; i < 10; i++)
    {
        // 先将任务加入列表，不立即等待
        tasks.Add(dB.GetDataByNameAsync("Name - 100000"));
        Console.WriteLine($"任务 {i} 已启动");
    }
    
    // 等待所有异步任务完成
    var products = await Task.WhenAll(tasks);
    
    // 遍历处理结果
    for (int i = 0; i < products.Length; i++)
    {
        Console.WriteLine($"任务 {i} 完成，产品ID：{products[i].Id}");
    }
}

2. 修复数据库连接的异步调用 #

把同步的sql.Open()替换为异步版本await sql.OpenAsync()，确保连接建立也是非阻塞的：

public async Task<Product> GetDataByNameAsync(string name)
{
    using (var sql = new SqlConnection("Data Source=(localdb)\\ProjectsV13;Initial Catalog=Inventory;Integrated Security=True;Connect Timeout=30;Encrypt=False;TrustServerCertificate=False;ApplicationIntent=ReadWrite;MultiSubnetFailover=False"))
    {
        // 异步打开数据库连接
        await sql.OpenAsync();
        string query = "Select id, Name from Product where Name = @name";

        SqlCommand cmd = new SqlCommand(query, sql);
        cmd.Parameters.Add("@name", System.Data.SqlDbType.VarChar).Value = name;

        Console.WriteLine("started");
        var reader = await cmd.ExecuteReaderAsync();
        Console.WriteLine("executing");

        if (await reader.ReadAsync())
        {
            return new Product()
            {
                Id = reader.GetInt32(0),
                Name = reader.GetString(1)
            };
        }

        return new Product();
    }
}

3. 注意事项 #

• 并行调用时要注意数据库连接池的上限，避免一次性创建过多连接导致性能下降或报错。
• 如果业务逻辑确实需要顺序执行（比如前一次调用的结果会影响后一次），那你原本的await写法是正确的，只是不属于并行异步场景。

内容的提问来源于stack exchange，提问作者venkatesh k