如何并行调用多仓储方法并获取结果以优化API性能

嘿，这个场景我太熟悉了！串行调用三个依赖HTTP请求的异步方法，总耗时是三个请求时间的总和，换成并行调用后，总耗时基本等于最慢那个请求的时间，性能提升立竿见影。下面给你具体的实现思路和代码：

核心思路 #

异步并行的关键是先启动所有异步任务，再等待所有任务完成，而不是逐个await（逐个await会导致串行执行）。我们可以用Task.WhenAll方法来等待多个Task同时完成。

修改后的代码实现 #

public async Task<object> GetTenantSettings(string source, string tenantId)
{
    // 先处理tenantId的转换，避免在任务内部抛出转换异常
    if (!int.TryParse(tenantId, out int tenantIdInt))
    {
        throw new ArgumentException("tenantId必须是有效的整数格式", nameof(tenantId));
    }

    // 启动三个异步任务，此时三个HTTP请求已经同时发起
    var tenantSettingsTask = _repository1.GetTenant(tenantId);
    var accountCountTask = _repository2.GetAccount(tenantId);
    var userCountTask = _repository3.GetUsers(source, tenantIdInt);

    // 等待所有任务完成，这里会异步等待，不会阻塞线程
    await Task.WhenAll(tenantSettingsTask, accountCountTask, userCountTask);

    // 获取每个任务的结果（因为已经await过WhenAll，Result不会阻塞，也能安全获取）
    var tenantSettings = tenantSettingsTask.Result;
    var accountCount = accountCountTask.Result;
    var userCount = userCountTask.Result;

    var tenantSettingsModel = MapTenant(accountCount, userCount, tenantSettings);
    return tenantSettingsModel;
}

关键细节解释 #

1. 任务启动时机：直接调用仓储的异步方法（比如_repository1.GetTenant(tenantId)）会立即启动任务，对应的HTTP请求会马上发起，而不是等到await的时候才启动。这是并行的核心。
2. Task.WhenAll的作用：这个方法会返回一个新的Task，当传入的所有Task都完成时，这个新Task才会完成。它会异步等待，不会占用额外线程阻塞。
3. 安全获取结果：在await Task.WhenAll之后，所有任务都已经完成，此时访问Task.Result不会阻塞线程，也不会抛出未处理的异常（如果任务失败，异常会在WhenAll的时候抛出）。

额外注意事项 #

异常处理 #

如果任何一个任务抛出异常，Task.WhenAll会将所有异常包装在AggregateException中抛出。你可以通过try-catch来处理：

try
{
    await Task.WhenAll(tenantSettingsTask, accountCountTask, userCountTask);
}
catch (AggregateException ex)
{
    foreach (var innerException in ex.InnerExceptions)
    {
        // 记录日志或者处理具体异常
        Console.WriteLine($"请求出错：{innerException.Message}");
    }
    // 根据业务需求选择重新抛出异常或者返回错误结果
    throw;
}

确保仓储方法是真正的异步 #

你的仓储接口返回Task<T>是对的，但要确保内部实现是真正的异步操作（比如使用HttpClient.GetAsync这类原生异步方法），而不是用Task.Run包装同步代码。如果是同步代码包装的异步，并行调用可能不会带来性能提升，反而浪费线程资源。

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