Controller中ContinueWith失效，后台异步任务日志不输出求助

原因分析 #

你当前代码里用_ = SubscribeForUpdates(callId)这种“火并忘记”的方式启动异步任务，在ASP.NET Core环境下会触发以下问题：

• 请求返回后，ASP.NET Core会回收当前请求的上下文资源，未等待的异步任务如果没脱离请求上下文，宿主（如Kestrel、IIS）可能直接终止该任务，导致后续的日志输出代码（Console.WriteLine）没机会执行。
• 断点调试时，调试器会保持进程运行，任务有足够时间完成，因此能正常看到日志。

解决方案 #

推荐方案：使用官方后台任务队列（最可靠） #

ASP.NET Core提供的IHostedService和后台任务队列实现，能确保后台任务脱离请求上下文独立执行，不受请求结束影响。

1. 实现后台任务队列

public interface IBackgroundTaskQueue
{
    void QueueBackgroundWorkItem(Func<CancellationToken, Task> workItem);
    Task<Func<CancellationToken, Task>> DequeueAsync(CancellationToken cancellationToken);
}

public class BackgroundTaskQueue : IBackgroundTaskQueue
{
    private readonly Channel<Func<CancellationToken, Task>> _queue;

    public BackgroundTaskQueue(int capacity)
    {
        var options = new BoundedChannelOptions(capacity)
        {
            FullMode = BoundedChannelFullMode.Wait
        };
        _queue = Channel.CreateBounded<Func<CancellationToken, Task>>(options);
    }

    public void QueueBackgroundWorkItem(Func<CancellationToken, Task> workItem)
    {
        if (workItem == null)
            throw new ArgumentNullException(nameof(workItem));
        
        _queue.Writer.TryWrite(workItem);
    }

    public async Task<Func<CancellationToken, Task>> DequeueAsync(CancellationToken cancellationToken)
    {
        return await _queue.Reader.ReadAsync(cancellationToken);
    }
}

2. 实现托管服务处理队列任务

public class QueuedHostedService : BackgroundService
{
    private readonly ILogger<QueuedHostedService> _logger;
    private readonly IBackgroundTaskQueue _taskQueue;

    public QueuedHostedService(IBackgroundTaskQueue taskQueue, ILogger<QueuedHostedService> logger)
    {
        _taskQueue = taskQueue;
        _logger = logger;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        _logger.LogInformation("后台任务队列服务启动");

        while (!stoppingToken.IsCancellationRequested)
        {
            var workItem = await _taskQueue.DequeueAsync(stoppingToken);

            try
            {
                await workItem(stoppingToken);
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, "执行后台任务时出错");
            }
        }

        _logger.LogInformation("后台任务队列服务停止");
    }
}

3. 注册服务到依赖注入容器

在Program.cs中添加：

builder.Services.AddSingleton<IBackgroundTaskQueue>(_ => new BackgroundTaskQueue(capacity: 100));
builder.Services.AddHostedService<QueuedHostedService>();

4. 修改Controller代码

private readonly IBackgroundTaskQueue _taskQueue;
private readonly IHttpClientFactory _httpClientFactory;
private readonly ILogger<YourController> _logger;

// 构造函数注入所需服务
public YourController(IBackgroundTaskQueue taskQueue, IHttpClientFactory httpClientFactory, ILogger<YourController> logger)
{
    _taskQueue = taskQueue;
    _httpClientFactory = httpClientFactory;
    _logger = logger;
}

[HttpPost("{callId}")]
public async Task<IActionResult> CreateSubs([FromRoute] string callId)
{
    var data = await ...// 读取数据库逻辑

    // 将订阅任务加入后台队列
    _taskQueue.QueueBackgroundWorkItem(async token =>
    {
        await SubscribeForUpdates(callId, token);
    });

    return Ok(data);
}

private async Task SubscribeForUpdates(string callId, CancellationToken cancellationToken)
{
    _logger.LogInformation("为客户端 {ConnectionId} 订阅通知", callId);

    var httpClient = _httpClientFactory.CreateClient();
    var requestMessage = new HttpRequestMessage
    {
        RequestUri = new Uri(httpClient.BaseAddress, $"subscribe/{callId}"),
        Method = HttpMethod.Get,
    };

    var result = await SendAsync<SubscriptionResponse>(requestMessage, cancellationToken);
    if (result.IsSuccess)
    {
        _logger.LogInformation("客户端 {CallId} 订阅成功", callId);
        // 建议用ILogger替代Console.WriteLine，更符合ASP.NET Core日志规范
        // Console.WriteLine("Success");
    }
    else
    {
        _logger.LogError("客户端 {CallId} 订阅失败", callId);
        // Console.WriteLine("Fail");
    }
}

临时方案：解绑请求上下文（仅降低风险，不保证任务完成） #

如果暂时不想引入后台队列，可以在异步方法的每个await后添加ConfigureAwait(false)，让任务脱离请求上下文：

private async Task SubscribeForUpdates(string callId)
{
    _logger.LogInformation("Subscribe client {ConnectionId} notifications", callId);

    var requestMessage = new HttpRequestMessage
    {
        RequestUri = new Uri(_httpClient.BaseAddress, $"subscribe/{callId}"),
        Method = HttpMethod.Get,
    };

    var result = await SendAsync<SubscriptionResponse>(requestMessage).ConfigureAwait(false);
    if (result.IsSuccess)
    {
        Console.WriteLine("Success");
    }
    else
    {
        Console.WriteLine("Fail");
    }
}

注意：此方案无法完全保证任务执行完成，当应用程序关闭或宿主回收进程时，未完成的任务仍会被终止。

避坑提醒 #

• 不要用Task.Run包装异步方法，这会浪费线程池线程，且同样无法保证任务完成。
• 避免直接使用Console.WriteLine，改用ASP.NET Core的ILogger组件，日志会被统一管理，更适合生产环境。

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