ASP.Net Core中BackgroundService消费AMQ队列降低CPU占用的方法

我有一个ASP.Net Core Web API应用，用于消费AMQ队列中的消息。目前将消费代码放在BackgroundService中，通过绑定Listener事件处理器实现消费。整体代码外层有一个while循环（检查取消令牌）以处理错误并重试订阅，同时还有一个内部while循环用于保持服务运行，但该循环无需执行任何操作。我的问题是，在这个内部while循环中应该执行什么操作（例如Task.Yield()、Task.Delay(某时长)）来避免不必要的CPU消耗？

public class ReceiverService : BackgroundService
{
    ...

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        ...
        
        while (!stoppingToken.IsCancellationRequested)
        {

            ...

            IConnectionFactory factory =
                new NMSConnectionFactory(
                    $"activemq:ssl://{parsed?["message"]}:51513?wireFormat.maxInactivityDuration=0");

            connection = await factory.CreateConnectionAsync(Username, Password);
            var session = await connection.CreateSessionAsync();

            var destination = await session.GetQueueAsync("queuename/" + subscriptionId);
            var consumer = await session.CreateConsumerAsync(destination);
            consumer.Listener += async message =>
            {
                // do stuff with message
                message.Acknowledge();
            };

            while (!stoppingToken.IsCancellationRequested)
            {
                await Task.Delay(0, stoppingToken);
            }

            await connection?.CloseAsync()!;
            await Task.Delay(1000, stoppingToken);
        }
    }
}

你当前使用的await Task.Delay(0, stoppingToken)会导致CPU空转——因为Delay(0)会立即完成，循环会被高频执行，完全达不到节省CPU的目的。针对内部空循环，推荐以下几种实用方案：

1. 给Task.Delay设置合理时长（最优选择） #

给Task.Delay设置非零时长，比如1000ms（1秒），这样循环每秒仅执行一次，CPU占用几乎可以忽略：

while (!stoppingToken.IsCancellationRequested)
{
    await Task.Delay(1000, stoppingToken);
}

这个方案简单可靠，既不会浪费CPU资源，又能及时响应取消令牌（Task.Delay会监听取消信号，触发时会抛出OperationCanceledException，BackgroundService会自动处理该异常，无需额外捕获）。

2. 用TaskCompletionSource等待取消信号（更高效） #

如果希望取消信号一触发就立即响应，不想等待Delay时长，可以用TaskCompletionSource监听取消令牌，完全避免循环：

var tcs = new TaskCompletionSource();
using (stoppingToken.Register(() => tcs.TrySetResult()))
{
    await tcs.Task;
}

将这段代码替换内部while循环即可。这种方式没有循环，CPU占用为0，且取消信号触发时会立即完成等待，是效率最高的方案。

3. 避免使用Task.Yield() #

不要用Task.Yield()，它会把任务放回线程池队列让线程处理其他任务，但循环依然会被快速重复执行，还是会造成不必要的CPU消耗，和Task.Delay(0)的问题类似。

额外代码优化建议 #

• 给Connection注册ExceptionListener，捕获连接异常，确保外层循环能正确触发重连逻辑；
• 内部Listener事件处理器用async void存在未捕获异常风险，建议在内部添加异常捕获逻辑；
• 创建Connection后记得调用await connection.StartAsync();，否则可能无法接收消息。

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