std::deque不能用于无锁并发,因其成员函数非原子、无内存序保证、无底层原子接口;需用atomic+循环数组从零实现,要求容量2的幂、原子指针/索引、安全内存回收及aba防护。

为什么标准库的 std::deque 不能直接用于无锁并发场景
因为 std::deque 的所有成员函数(包括 push_front、pop_back、size)都不是原子的,内部存在多处非原子读写和潜在的内存重排。多个线程同时调用时会触发数据竞争,UB(未定义行为)是常态,不是偶然。
更关键的是,它没有提供对底层节点指针或容量状态的原子访问接口,无法在用户态实现安全的 CAS 循环。试图“包装”它加锁就失去了无锁意义;试图“绕过”它做指针操作则直接越界或破坏其内存布局。
所以必须从零构造:用原子指针管理节点、分离 head/tail 索引、避免 ABA 问题、处理内存回收——这些都不是 std::deque 能帮上忙的。
使用 std::atomic + 循环数组实现轻量级无锁双端队列的关键约束
循环数组方案(如 Harris-Michael 风格)适合固定大小、高吞吐、低延迟场景,但有硬性前提:
-
capacity必须是 2 的幂(便于位运算取模,避免分支和除法) - 每个槽位需用
std::atomic<t></t>或带标记的std::atomic<uintptr_t></uintptr_t>存储指针,并支持compare_exchange_weak - head/tail 索引必须为
std::atomic<size_t></size_t>,且更新时需用memory_order_acq_rel保证顺序可见性 - 不能直接 delete 节点:出队后对象所有权移交调用方,但指针本身需通过 Hazard Pointer 或 epoch-based reclamation 延迟释放,否则可能 ABA 或访问已释放内存
示例片段(简化版入队):
bool push_back(T* item) {
size_t tail = tail_.load(std::memory_order_acquire);
size_t next_tail = (tail + 1) & mask_;
if (next_tail == head_.load(std::memory_order_acquire)) return false; // full
slots_[tail].store(item, std::memory_order_release);
tail_.store(next_tail, std::memory_order_release);
return true;
}
std::atomic<uintptr_t></uintptr_t> 打包指针+版本号防 ABA 的实际写法
单纯用 std::atomic<t></t> 在多生产者场景下极易遭遇 ABA:线程 A 读到指针 P,被抢占;线程 B 弹出 P、归还内存、又压入新节点到同一地址 P;线程 A 恢复后 CAS 成功,却误认为仍是原节点。
解决方法是把指针和单调递增的版本号打包进一个整数(如 uintptr_t),用 std::atomic<uintptr_t></uintptr_t> 操作:
- 假设指针占 48 位,版本号占 16 位(足够应付绝大多数生命周期)
- 封装读写宏:
#define PTR_MASK ((1ULL 、<code>#define VER_MASK (~PTR_MASK) - CAS 时必须同时比对指针值和版本号,更新时版本号 +1
- 注意:x86-64 支持
cmpxchg16b,但需对齐到 16 字节;ARM64 则依赖ldxp/stxp,务必检查编译器是否生成正确指令(用objdump验证)
错误示范:std::atomic<t> ptr_; ptr_.compare_exchange_weak(expected, desired)</t> —— 这类代码在 MP 环境下本质不可靠。
为什么多数项目不该自己手写无锁 deque
真正可靠的无锁双端队列需要处理:内存模型边界(acquire/release/fence 组合)、回收时机(Hazard Pointer 实现至少 300 行 C++)、调试难度(竞态几乎不可复现)、以及 x86/ARM 指令语义差异。一个 typo 就可能导致偶发崩溃或静默数据损坏。
更现实的选择是:
- 用
moodycamel::ConcurrentQueue(单生产者/单消费者模式下自动退化为无锁,且提供enqueue_bulk/try_dequeue_bulk减少 CAS 频次) - 若需严格双端,考虑
libcds中的cds::container::BasketQueue或FeldmanDeque(基于论文实现,含完整内存回收) - 业务层做批处理:用有锁
std::deque+ 工作线程批量搬运任务,吞吐未必更低,但稳定性可控
自己实现的临界点通常只出现在高频实时系统(如 HFT 网关)且 profiling 明确卡在队列 CAS 上——其余情况,先压测再决定是否值得啃这块硬骨头。
C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!











