不能直接用 std::queue 实现无锁队列，因其所有操作非原子且无内存序保证；SPSC 可用 std::atomic 索引+2的幂数组配合 acquire/release 实现；MPMC 则需 compare_exchange_weak 或 MSQueue 等复杂机制。
为什么不能直接用 std::queue 实现无锁队列
因为 std::queue 本身不是线程安全的，它的所有操作（push、pop、front）都不带原子语义，更不保证内存序。即使你把底层容器换成 std::array，也依然无法规避竞态：两个线程同时 push 可能写坏 tail 索引；一个线程在读 front() 的同时另一个线程正在 pop()，可能读到未初始化或已释放的数据。
真正可行的起点是手动管理两个原子索引（head 和 tail），配合循环缓冲区（circular buffer），并严格使用 memory_order_acquire/memory_order_release 控制重排。
怎么用 std::atomic + 数组实现单生产者单消费者（SPSC）队列
SPSC 是唯一能靠纯原子索引+数组“手写到位”的场景，无需复杂标记位或双字CAS。核心是：生产者只改 tail，消费者只改 head，两者访问不同数组元素，冲突仅发生在索引更新本身。
-
tail和head都声明为std::atomic，初始值为 0 - 缓冲区大小必须是 2 的幂（如 1024），方便用位运算取模：
index & (capacity - 1) -
push()先读tail，计算写位置，写数据，再原子增tail（用fetch_add+memory_order_relaxed） -
pop()类似，但读head后需先检查是否head == tail（空），且写入前要确保该位置已被生产者写完 —— 这里要用memory_order_acquire读tail，保证能看到之前所有写入
示例关键片段：
class SPSCQueue {
static constexpr size_t CAPACITY = 1024;
std::atomic<size_t> head_{0}, tail_{0};
T buffer_[CAPACITY];
public:
bool push(const T& val) {
const size_t tail = tail_.load(std::memory_order_relaxed);
const size_t next_tail = (tail + 1) & (CAPACITY - 1);
if (next_tail == head_.load(std::memory_order_acquire)) return false; // full
buffer_[tail & (CAPACITY - 1)] = val;
tail_.store(next_tail, std::memory_order_release);
return true;
}
// pop 类似，注意 head_ load 用 acquire，tail_ load 用 acquire（判断非空）
};
</size_t>
多生产者或多消费者（MPMC）为什么不能简单扩展 SPSC
一旦出现多个生产者，tail_.fetch_add(1) 虽然原子，但两个线程可能拿到相同旧值，导致写入同一槽位；同理，多个消费者对 head 的竞争会让出队逻辑失效。此时必须引入额外同步机制。
- 常见做法是用
std::atomic循环重试，但失败路径会显著降低吞吐::compare_exchange_weak - 更稳健的是采用 Michael-Scott 算法（MSQueue），它用链表节点 + 原子指针（
std::atomic）实现，但需要堆分配，且pop涉及 ABA 问题，必须用带版本号的指针（如std::atomic打包指针+计数） - 如果你坚持固定大小，又需要 MPMC，几乎只能依赖第三方库（如
moodycamel::ConcurrentQueue）或内核级原语（Linuxmembarrier），纯标准 C++ 很难兼顾正确性与性能
容易被忽略的内存序和对齐陷阱
很多人写了原子操作却忘了内存序——比如用 memory_order_relaxed 读 tail 判断是否为空，会导致消费者永远看不到新数据；或者没给缓冲区加 alignas(cache_line_size)，引发伪共享（false sharing）：head 和 tail 被映射到同一缓存行，一个线程改 head 会让另一个线程的 tail 缓存失效，性能暴跌。
-
head、tail必须各自独占缓存行（通常 64 字节），中间用alignas(64)填充 - 判断队列空/满时，读对方索引必须用
memory_order_acquire（确保看到其之前所有写） - 更新自己索引后，写数据必须完成于索引更新之前，所以写数据用普通赋值，索引更新用
memory_order_release
最麻烦的其实不是代码怎么写，而是验证它真没竞态——你需要用 ThreadSanitizer 或 libcds 的测试框架跑大量并发 push/pop，否则很容易在线上压测时才暴露丢数据或死锁。
C++免费学习笔记（深入）：立即使用
在学习笔记中，你将探索 C++ 的入门与实战技巧！
