如何通过计数器结合Task运行.NET Core BackgroundService？

核心原因分析 #

你遇到的问题本质是容量计数器递减后，没有通知后台服务的主循环继续执行任务创建逻辑，或者主循环的等待机制有缺陷，导致计数器空出名额后无法被检测到。

具体解决方法 #

1. 替换手动计数器为SemaphoreSlim（推荐） #

手动维护_capacityCounter很容易出现通知遗漏，直接用.NET自带的SemaphoreSlim控制并发，它自带等待/唤醒机制，能完美解决这个问题：

private readonly SemaphoreSlim _concurrencySemaphore;
private const int ConsumeCapacityPerMinute = 10;

public WebWorkGenerator()
{
    // 初始化信号量，最大并发数10
    _concurrencySemaphore = new SemaphoreSlim(ConsumeCapacityPerMinute, ConsumeCapacityPerMinute);
}

protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
    while (!stoppingToken.IsCancellationRequested)
    {
        // 等待信号量可用，自动阻塞直到有空闲名额
        await _concurrencySemaphore.WaitAsync(stoppingToken);

        // 后台执行任务，避免阻塞主循环
        _ = Task.Run(async () =>
        {
            try
            {
                Console.WriteLine($"Working {ConsumeCapacityPerMinute - _concurrencySemaphore.CurrentCount}/{ConsumeCapacityPerMinute}");
                await ProcessItems();
            }
            finally
            {
                // 任务完成后释放信号量，自动唤醒等待的主循环
                _concurrencySemaphore.Release();
                Console.WriteLine($"Released, remaining capacity: {_concurrencySemaphore.CurrentCount}");
            }
        }, stoppingToken);

        // 短延迟避免主循环空转，根据实际需求调整
        await Task.Delay(50, stoppingToken);
    }
}

2. 给手动计数器添加通知机制（若坚持自定义计数器） #

如果必须手动维护_capacityCounter，需要搭配ManualResetEventSlim实现容量变化的通知：

private int _capacityCounter;
private const int MaxCapacity = 10;
private readonly ManualResetEventSlim _capacityAvailableEvent = new ManualResetEventSlim(true);

protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
    while (!stoppingToken.IsCancellationRequested)
    {
        // 等待容量可用信号
        _capacityAvailableEvent.Wait(stoppingToken);

        // 原子操作递增计数器，避免并发冲突
        if (Interlocked.Increment(ref _capacityCounter) > MaxCapacity)
        {
            // 超过最大容量，回滚计数器并关闭信号
            Interlocked.Decrement(ref _capacityCounter);
            _capacityAvailableEvent.Reset();
            continue;
        }

        // 后台执行任务
        _ = Task.Run(async () =>
        {
            try
            {
                Console.WriteLine($"Working {_capacityCounter}/{MaxCapacity}");
                await ProcessItems();
            }
            finally
            {
                // 原子递减计数器
                Interlocked.Decrement(ref _capacityCounter);
                // 触发容量可用信号，通知主循环检查
                _capacityAvailableEvent.Set();
            }
        }, stoppingToken);

        await Task.Delay(50, stoppingToken);
    }
}

3. 确保计数器递减逻辑绝对执行 #

不管ProcessItems成功还是失败，必须把计数器递减放在finally块中，否则异常会导致计数器卡住：

// 错误写法：异常时不会递减计数器
await ProcessItems();
Interlocked.Decrement(ref _capacityCounter);

// 正确写法
try
{
    await ProcessItems();
}
finally
{
    Interlocked.Decrement(ref _capacityCounter);
    // 如果用了通知事件，这里也要调用Set()
}

4. 避免主循环被阻塞 #

主循环里不能用同步阻塞操作（比如Task.Result、Wait()），必须全程用await异步等待，否则会导致主循环卡住，无法响应计数器的变化。

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