如何构建一个基于消息队列的复杂任务解耦系统架构？

本文共计1067个文字，预计阅读时间需要5分钟。

不需要引入Boost、ZeroMQ或Kafka，单进程内模块解耦，标准库三件套完全胜任。关键不是能不能，而是同步逻辑是否稳定——如`Pop`等等待空间序列时不能急等，`Push`后必须精细唤醒。

• std::unique_lock<:mutex></:mutex> 必须包住所有队列读写，包括 empty() 判断和 pop() 调用，否则存在竞态窗口
• cv.wait(lock, []{ return !q.empty(); }) 的 lambda 必须捕获真实状态，不能写成 q.size() > 0（非原子）
• 多个消费者共用一个队列时，用 notify_one() 比 notify_all() 更轻量；若消费者数量动态变化，需额外加计数器防虚假唤醒
• 别在构造函数里启动消费线程——对象未完全构造完成就跑线程，this 可能悬空

模板设计要支持移动语义，否则性能掉一截

消息类型可能是大结构体、std::vector 或带资源的类，不走移动会触发深拷贝，吞吐直接腰斩。