c++怎么实现高并发下的无锁队列_c++ std::atomic原子变量与CAS操作【详解】

std::atomic 不能直接实现无锁队列，因其仅保证单变量原子性，而队列操作需多位置协同更新且面临 ABA 问题；真正无锁需 CAS 循环+内存序控制，SPSC 场景可用 std::atomic + compare_exchange_weak 安全实现，MPMC 则必须引入版本号防 ABA。

为什么 std::atomic 不能直接实现无锁队列

因为 std::atomic 只保证单个变量的原子读写，而队列操作（如入队/出队）需要**多个内存位置协同更新**（比如同时修改 head、tail 和节点数据），仅靠单个 std::atomic 无法避免 ABA 问题或中间态不一致。真正无锁（lock-free）队列必须基于 CAS（Compare-And-Swap）循环重试 + 内存序控制，且通常需自定义节点结构和指针管理。

用 std::atomic + CAS 实现简易单生产者单消费者（SPSC）无锁队列

SPSC 是唯一能用纯 std::atomic + compare_exchange_weak 安全实现的常见场景。关键点：

head 和 tail 必须是 std::atomic，且初始化为同一哨兵节点
入队时对 tail 执行 CAS：期望值为当前 tail，新值为新节点；失败则重试
出队时对 head 执行 CAS：期望值为当前 head，新值为 head->next
必须用 memory_order_acquire（读）和 memory_order_release（写）防止指令重排
不能直接 delete 节点——SPSC 下可复用内存池，否则需配合 hazard pointer 或 RCU

struct Node {
    int data;
    Node* next;
};
class SPSCQueue {
std::atomic> head_;
std::atomic> tail_;
// ... 构造函数中分配哨兵节点
public:
bool tryenqueue(int val) {
Node node = new Node{val, nullptr};
Node tail = tail.load(std::memory_orderacquire);
while (!tail.compare_exchange_weak(tail, node, std::memory_order_acq_rel)) {
// CAS 失败，说明 tail 已被其他线程推进，继续重试
}
tail->next = node; // 此时 tail 仍是旧 tail，安全写入
return true;
}
};