spsc场景下可用原子整数+循环数组实现无锁,因生产者独占tail、消费者独占head,无竞态;只需memory_order_relaxed,关键点用acquire/release;容量须为2的幂以支持位掩码索引;push/pop必须用memcpy避免构造/析构。

为什么 SPSC 场景下可以用原子整数 + 循环数组实现无锁
因为单生产者单消费者(SPSC)天然避免了竞态:两个线程各自只修改一个指针(head 或 tail),不需要 CAS 重试逻辑。只要用 std::atomic 保证读写不被重排、不被缓存延迟即可,连内存序都可简化为 memory_order_relaxed(仅需在关键点加 acquire/release)。
常见错误是直接对裸 int 做自增后取模,导致读写撕裂或编译器乱序——必须用 std::atomic<int></int> 封装索引,并显式控制内存序。
-
tail由生产者独占更新,用store(tail, std::memory_order_release)发布新元素 -
head由消费者独占更新,用load(head, std::memory_order_acquire)获取旧元素 - 判断是否为空/满时,用
(tail.load() - head.load()) % capacity,但注意负数取模行为,建议用位运算替代(见下条)
如何用 2 的幂次容量 + 位掩码代替取模提升性能
循环数组的索引计算若用 % N,在 x86 上虽有优化,但仍是分支+除法;而设容量为 2 的幂(如 1024),可用 index & (capacity - 1) 替代,零开销且无分支。
这要求构造时强制检查:assert((capacity & (capacity - 1)) == 0),否则位掩码失效。很多开源实现(如 boost::lockfree::spsc_queue)默认只接受 2 的幂容量。
- 容量必须是 2 的幂,否则
index & (capacity - 1)会跳过部分槽位 -
tail和head原生存储为size_t(不取模),靠位掩码在访问数组时截断 - 判空逻辑为
head.load() == tail.load();判满为(tail.load() - head.load()) == capacity(不是== capacity - 1),因为满时恰好差一个位置
为什么 push/pop 必须用 memcpy 而非 operator=
队列元素类型可能是非 trivially copyable(如含虚函数、自定义移动构造的类),而无锁结构不能依赖异常安全或临时对象生命周期——所有操作必须是原子的、无状态的、无栈展开风险的。
memcpy 是唯一能跨线程安全搬运任意 POD/ trivially copyable 对象的手段。C++20 起可改用 std::bit_cast(仅限 trivial 类型),但兼容性不如 memcpy。
- push 时:先算出写入位置
buffer[tail & mask],再memcpy(&buffer[pos], &data, sizeof(T)) - pop 时:先
memcpy(&data, &buffer[head & mask], sizeof(T)),再更新head - 禁止对
T调用任何构造/析构函数——对象生命周期完全由外部管理
实际使用时最容易忽略的三个细节
很多人照抄代码能跑通,但在压测或跨平台时崩,问题往往出在这些地方:
- 没有对齐缓冲区:若
T要求 16 字节对齐(如__m128),而new char[N]只保证 8 字节对齐,需用aligned_alloc或std::aligned_storage - 忘记 memory_order_acq_rel 在边界点的作用:比如 pop 后要确保之前读到的数据已从缓存刷出,否则可能看到脏值;应在 load
head后加std::atomic_thread_fence(std::memory_order_acquire)(或直接用load(acquire)) - 未处理 ABA 问题?SPSC 下根本不存在 ABA:只有一个线程改
head,改完不会绕回原值再改一次;所以无需版本号或 double-width CAS
真正难的是把 buffer 生命周期、对齐、内存序、类型约束这几件事串成一条不中断的链——漏掉任一环,就不是“无锁”,而是“看起来像无锁的随机崩溃”。
C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!











