.NET 8 Worker Service中Task.WaitAll抛出任务已取消的AggregateException

可能的原因 #

• Quartz Job上下文的取消令牌触发：Quartz的IJob.Execute方法会传入IJobExecutionContext，其中包含的CancellationToken会在Job被中止（如服务停止、Job超时）时触发。如果你的TPL任务未关联该令牌，系统会强制取消这些任务，导致Task.WaitAll抛出AggregateException。
• API调用超时被标记为取消：HttpClient的超时本质是通过取消令牌实现的，若API请求超时，会抛出TaskCanceledException，被包装进AggregateException中。
• 同步等待引发的资源冲突：在异步优先的Worker Service环境中，使用Task.WaitAll这类同步等待方法，可能导致线程资源被长期占用，进而触发系统的取消逻辑。

解决方案 #

1. 关联Quartz的取消令牌 #

在创建API调用任务时，传入Quartz Job上下文的CancellationToken，确保任务能响应Job的中止信号：

public async Task Execute(IJobExecutionContext context)
{
    var cancellationToken = context.CancellationToken;
    
    // 将令牌传入API调用方法
    var apiTask1 = CallExternalApi1Async(cancellationToken);
    var apiTask2 = CallExternalApi2Async(cancellationToken);
    
    // 优先使用异步等待替代同步的Task.WaitAll
    await Task.WhenAll(apiTask1, apiTask2);
    
    // 处理API响应
    var result1 = await apiTask1;
    var result2 = await apiTask2;
    // ...后续处理逻辑
}

2. 排查并处理API超时问题 #

检查HttpClient的超时配置，或为API调用设置单独的超时令牌，避免因超时被误判为任务取消：

private async Task<string> CallExternalApi1Async(CancellationToken token)
{
    using var linkedCts = CancellationTokenSource.CreateLinkedTokenSource(token);
    // 为该API设置单独的超时（比如30秒）
    linkedCts.CancelAfter(TimeSpan.FromSeconds(30));
    
    var response = await _httpClient.GetAsync("https://api.example.com/endpoint1", linkedCts.Token);
    response.EnsureSuccessStatusCode();
    return await response.Content.ReadAsStringAsync(token);
}

3. 调整Quartz Job的超时配置 #

检查Quartz Job的配置，若设置了过短的超时时间，会导致Job未完成就被中止：

// 示例：调整Job超时为5分钟
var jobDetail = JobBuilder.Create<YourJob>()
    .WithIdentity("YourJob")
    .WithDescription("定时执行的API调用任务")
    .Build();

var trigger = TriggerBuilder.Create()
    .WithIdentity("YourJobTrigger")
    .StartNow()
    .WithSimpleSchedule(x => x
        .WithIntervalInMinutes(10)
        .RepeatForever())
    // 取消或延长超时时间
    .WithTimeout(TimeSpan.FromMinutes(5))
    .Build();

4. 正确捕获并分析异常 #

在代码中捕获AggregateException，遍历内部异常定位具体问题：

try
{
    Task.WaitAll(apiTask1, apiTask2);
}
catch (AggregateException ex)
{
    foreach (var innerException in ex.InnerExceptions)
    {
        if (innerException is TaskCanceledException cancelEx)
        {
            // 记录详细日志，排查取消原因
            _logger.LogError(cancelEx, "任务被取消：{Reason}", cancelEx.InnerException?.Message ?? "无额外信息");
        }
        else
        {
            _logger.LogError(innerException, "API调用发生错误");
        }
    }
}

关键建议 #

Worker Service和Quartz.NET均推荐使用异步编程模型，避免使用Task.WaitAll、Task.Result这类同步等待方法，不仅能减少线程资源占用，还能更自然地处理取消令牌和异常。

内容的提问来源于stack exchange，提问作者Sk Shahnawaz-ul Haque