.NET中单例对象多线程访问问题：ASP.NET Core任务队列实现咨询

问题1：当前实现能否稳定运行，你的判断是否正确 #

你的判断方向是对的，该实现完全无法稳定运行，实际风险比你提到的问题更严重：

• LinkedList<T> 本身不是线程安全类型，当请求线程写入队列、Worker线程读取队列的并发操作发生时，会直接破坏链表的内部结构，轻则出现任务丢失、重复执行的问题，重则直接抛出NullReferenceException、InvalidOperationException等运行时异常导致服务崩溃。
• 当前Worker的实现是无等待死循环，队列空的时候会持续占满CPU核心空转，不仅浪费服务器资源，还会拉高整个服务的请求响应延迟。
• 队列空时调用GetNextEvent方法访问Queue.Last.Value会直接抛出异常，直接导致整个后台服务终止运行。

问题2：改为静态类/静态队列是否有差异 #

没有本质差异。
静态队列和单例实例的队列属性，本质都是进程内全局共享的存储对象，多线程并发访问的线程安全问题完全一致，不会解决现有任何故障，甚至静态变量的生命周期和进程绑定，若后续需要扩展多队列场景会更难维护。

问题3：可行的优化建议 #

• 替换为线程安全的异步队列

优先使用.NET官方提供的System.Threading.Channels实现生产者消费者模式，这是当前.NET生态下最适合该场景的队列实现，原生支持异步等待、线程安全、容量限制，不用自己处理并发同步逻辑。
示例实现：

public interface IEventQueue
{
    ValueTask EnqueueAsync(Func<CancellationToken, Task> taskFunc, CancellationToken ct = default);
    ValueTask<Func<CancellationToken, Task>> DequeueAsync(CancellationToken ct = default);
}

public class EventQueue : IEventQueue
{
    private readonly Channel<Func<CancellationToken, Task>> _queue;

    public EventQueue(int capacity = 1000)
    {
        // 配置有界队列防止内存溢出
        var options = new BoundedChannelOptions(capacity)
        {
            FullMode = BoundedChannelFullMode.Wait
        };
        _queue = Channel.CreateBounded<Func<CancellationToken, Task>>(options);
    }

    public ValueTask EnqueueAsync(Func<CancellationToken, Task> taskFunc, CancellationToken ct = default)
    {
        return _queue.Writer.WriteAsync(taskFunc, ct);
    }

    public ValueTask<Func<CancellationToken, Task>> DequeueAsync(CancellationToken ct = default)
    {
        return _queue.Reader.ReadAsync(ct);
    }
}

• 优化Worker实现

适配异步队列，增加异常处理、优雅停机逻辑：

public class QueueWorker : BackgroundService
{
    private readonly IEventQueue _queue;
    private readonly ILogger<QueueWorker> _logger;

    public QueueWorker(IEventQueue queue, ILogger<QueueWorker> logger)
    {
        _queue = queue;
        _logger = logger;
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        while (!stoppingToken.IsCancellationRequested)
        {
            try
            {
                // 队列空时会异步等待，不占用CPU
                var taskFunc = await _queue.DequeueAsync(stoppingToken);
                await taskFunc(stoppingToken);
            }
            catch (OperationCanceledException)
            {
                // 停机信号触发，正常退出
                break;
            }
            catch (Exception ex)
            {
                // 单个任务异常只打日志，不终止整个Worker
                _logger.LogError(ex, "执行队列任务时发生异常");
            }
        }
    }
}

• 其他补充优化

  • 业务代码中入队时传入当前请求的取消令牌，请求取消时可以自动终止对应任务的入队/执行流程
  • 可根据业务场景配置队列的满溢策略，比如超过容量时丢弃旧任务、拒绝新任务等
  • 增加队列监控指标，比如队列长度、任务执行成功率、耗时等，方便后续排查性能问题

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