C#中如何复用线程？WebSocket高频消息计算场景优化

核心逻辑 #

你要的单队列顺序处理+线程复用，本质是让一个常驻后台线程循环消费任务队列——直接给已有线程“追加任务”是做不到的，因为线程执行完指定方法后会自动终止，必须让线程保持运行状态，不断从队列里取任务执行。

具体实现方案 #

用BlockingCollection<T>做线程安全的任务队列（它自带阻塞等待功能，队列为空时线程会自动挂起，不浪费CPU），配合一个命名后台线程持续处理队列任务，完美匹配你的需求。

1. 定义任务队列并初始化常驻线程 #

// 线程安全的任务队列，替换YourMsgType为你实际的消息类型
private readonly BlockingCollection<YourMsgType> _taskQueue = new BlockingCollection<YourMsgType>();

// 初始化命名的后台处理线程
public void InitWorkerThread()
{
    var workerThread = new Thread(ProcessTaskQueue)
    {
        Name = "WebSocketMsgProcessor", // 给线程命名
        IsBackground = true // 设置为后台线程，程序退出时自动终止
    };
    workerThread.Start();
}

2. 实现线程的任务循环逻辑 #

private void ProcessTaskQueue()
{
    // 循环从队列取任务，队列为空时自动阻塞等待新任务
    foreach (var msgInfo in _taskQueue.GetConsumingEnumerable())
    {
        Do_work(msgInfo);
    }
}

3. 修改WebSocket消息接收逻辑 #

不再每次创建新线程，而是把消息扔进队列即可：

client.MsgRecieved.Subscribe(info =>
{
    _taskQueue.Add(info); // 消息入队，后台线程自动处理
});

4. 优雅关闭（可选） #

如果需要程序退出时处理完剩余任务，记得调用：

// 标记队列不再接受新任务，线程处理完剩余任务后会自动退出
_taskQueue.CompleteAdding();

关键说明 #

• 为什么不用ThreadPool/Task？你明确要求单队列顺序处理，而ThreadPool默认会用多线程并行执行，无法保证任务的处理顺序，不符合你的需求。
• 注意Do_work内部不要有长时间阻塞，否则会卡住整个任务队列，影响后续消息处理。

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