IHostedService后台任务锁定ASP.NET Core应用问题求助

问题描述 #

希望在独立线程中运行数据同步任务，但该任务导致整个ASP.NET Core服务器被锁定。尝试使用Task与Thread两种方式实现，始终出现应用锁定情况，相关代码如下：

ScopedProcessingService代码 #

public interface IScopedProcessingService
{
    Task DoWork(CancellationToken stoppingToken);
}

public class ScopedProcessingService : IScopedProcessingService
{
    private int executionCount = 0;
    private readonly ISynchronizationBackgroundService _syncService;

    public ScopedProcessingService(ISynchronizationBackgroundService syncService)
    {
        _syncService= syncService;
    }

    public Task DoWork(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            try
            {
                _syncService.Synchronize();
            }
            catch (Exception ex)
            {
                Log.Error($"SYNCHRONIZATION ERROR {ex.Message} {ex.InnerException?.Message}");
            }

            Thread.Sleep(5000);
        }
        return Task.CompletedTask;
    }
}

消费者代码 #

public class ConsumeScopedServiceHostedService : BackgroundService
{
    public IServiceProvider Services { get; }
    public ConsumeScopedServiceHostedService(IServiceProvider services)
    {
        Services = services;
    }

    protected override Task ExecuteAsync(CancellationToken stoppingToken)
    {
        Thread t = new Thread(() =>
        {
            using (var scope = Services.CreateScope())
            {
                var scopedProcessingService =
                    scope.ServiceProvider
                        .GetRequiredService<IScopedProcessingService>();

                scopedProcessingService.DoWork(stoppingToken);
            }
        });
        t.Start();
        return Task.CompletedTask;
    }
}

服务注册代码 #

services.AddHostedService<ConsumeScopedServiceHostedService>();
services.AddScoped<IScopedProcessingService, ScopedProcessingService>();
services.AddScoped<ISynchronizationBackgroundService, SynchronizationBackgroundService>();

问题排查与解决建议 #

• 核心排查点：Synchronize()方法
  服务器锁定的根源大概率在_syncService.Synchronize()内部。检查该方法是否存在以下情况：

  • 长时间阻塞的同步操作（如未做异步处理的数据库查询、第三方API调用）
  • 共享资源未正确释放导致的死锁
  • 占用过量CPU/IO资源，挤占主线程资源

• 替换阻塞式等待为异步等待
  Thread.Sleep(5000)会直接阻塞当前线程，浪费线程池资源。改为异步等待：

  await Task.Delay(5000, stoppingToken);
  

• 修正DoWork的异步实现
  当前DoWork是“假异步”（返回Task但内部全是同步阻塞逻辑），改成真正的异步方法：

  public async Task DoWork(CancellationToken stoppingToken)
  {
      while (!stoppingToken.IsCancellationRequested)
      {
          try
          {
              // 优先使用异步版本的同步方法
              await _syncService.SynchronizeAsync(stoppingToken);
              // 若只能用同步方法，用Task.Run包装避免阻塞线程池
              // await Task.Run(() => _syncService.Synchronize(), stoppingToken);
          }
          catch (Exception ex)
          {
              Log.Error($"SYNCHRONIZATION ERROR {ex.Message} {ex.InnerException?.Message}");
          }
  
          await Task.Delay(5000, stoppingToken);
      }
  }
  

• 简化BackgroundService实现
  无需手动创建Thread，BackgroundService本身就是后台服务框架，直接依托框架管理线程：

  protected override async Task ExecuteAsync(CancellationToken stoppingToken)
  {
      using (var scope = Services.CreateScope())
      {
          var scopedProcessingService = scope.ServiceProvider.GetRequiredService<IScopedProcessingService>();
          await scopedProcessingService.DoWork(stoppingToken);
      }
  }
  

• 监控资源占用
  使用dotnet counters、dotnet trace等工具查看线程池状态、数据库连接池占用、CPU/内存使用率，定位具体阻塞点。

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