如何在同步方法中正确等待多I/O任务并单独处理异常？

串行原因分析 #

1. 异步方法未真正实现异步 #

如果GetSomeDataFromEndpoint内部是用同步逻辑包装的Task（比如调用SendAsync后直接用.Result或.Wait()阻塞等待），那么每次调用该方法都会同步完成整个请求，任务根本无法并行启动，自然表现为串行执行。

要验证这点，检查方法实现，确保它是真正的异步：

public async Task<SomeData> GetSomeDataFromEndpoint(int id)
{
    var request = new HttpRequestMessage(HttpMethod.Get, $"api/data/{id}");
    using (var response = await httpClient.SendAsync(request, HttpCompletionOption.ResponseHeadersRead))
    {
        response.EnsureSuccessStatusCode();
        return await response.Content.ReadAsAsync<SomeData>();
    }
}

2. HTTP连接数限制 #

.NET Framework 4.8中ServicePointManager.DefaultConnectionLimit默认值为2，同一域名下最多同时建立2个HTTP连接，超出的请求会排队等待，看起来和串行执行一致。需要提前调高这个值。

优化后的并行实现 #

// 全局初始化时设置连接数（只需一次，比如在程序启动代码里）
ServicePointManager.DefaultConnectionLimit = 10; // 根据请求数量调整，可设为请求数或更大值

var listOfRequests = new List<int> {1,2,3,4,5,6,7,8};
var tasks = new Dictionary<int, Task<SomeData>>();

// 批量启动所有异步任务
foreach (var id in listOfRequests)
{
    tasks.Add(id, httpClient.GetSomeDataFromEndpoint(id));
}

// 同步等待所有任务完成
try
{
    Task.WhenAll(tasks.Values).Wait();
}
catch (AggregateException)
{
    // 后续会逐个检查任务状态，此处无需处理具体异常
}

// 逐个处理每个请求的结果与异常
foreach (var kvp in tasks)
{
    var requestId = kvp.Key;
    var task = kvp.Value;

    if (task.IsCompletedSuccessfully)
    {
        var result = task.Result;
        // 处理成功数据
        Console.WriteLine($"请求{requestId}成功：{result}");
    }
    else if (task.IsFaulted)
    {
        var exception = task.Exception?.InnerException ?? task.Exception;
        // 明确异常归属，处理错误
        Console.WriteLine($"请求{requestId}失败：{exception.Message}");
    }
    else if (task.IsCanceled)
    {
        Console.WriteLine($"请求{requestId}被取消");
    }
}

关键注意事项 #

• 必须保证GetSomeDataFromEndpoint是真正异步实现，禁止在方法内部使用.Result或.Wait()阻塞线程。
• ServicePointManager.DefaultConnectionLimit的设置要适度，过大可能导致目标服务器触发限流，需根据实际场景调整。
• 若涉及HTTPS请求，可额外设置ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls12 | SecurityProtocolType.Tls13，避免协议兼容性问题导致的请求阻塞。

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