有界无锁MPSC队列读取异常：Pop返回True但值为0的排查与修复

问题原因 #

1. Pop函数的指令重排隐患 #

Pop函数中，编译器或CPU可能将data[cons_tail % SIZE]的读取操作重排到prod_tail.load()检查之前。单线程场景下编译器认为这种重排安全，但多线程环境中会出现以下时序：

• Pop线程先读取到数组初始值0
• 随后检查prod_tail发现存在未消费的数据
• 最终将提前读取到的0赋值给out并返回true
  这是因为cons_tail是普通非原子变量，编译器无法感知到它与其他线程修改的prod_tail、data之间的依赖关系，因此允许指令重排。

2. Push函数的prod_tail CAS死循环缺陷 #

Push的最后一步更新prod_tail时，循环内未重新加载最新的prod_tail值到local_prod_head。当其他生产者线程已将prod_tail推进到比当前local_prod_head更大的值时，当前线程的CAS会持续失败，陷入死循环。虽然这不是当前问题的直接诱因，但属于实现中的严重漏洞。

修复方案 #

修复Pop的指令重排问题 #

通过原子操作内存序约束，确保prod_tail的读取操作先于data的读取执行：

bool Pop(T &out) {
    // 使用acquire内存序，阻止后续读取重排到该操作之前
    int64_t current_prod_tail = prod_tail.load(std::memory_order_acquire);
    if (cons_tail >= current_prod_tail)
        return false;
    out = data[cons_tail % SIZE];
    cons_tail += 1;
    return true;
}

memory_order_acquire语义可以保证：任何在其他线程中通过release语义发布的写操作，对当前线程都是可见的，同时阻止后续的读取操作被重排到该load操作之前。

修复Push的CAS死循环问题 #

在prod_tail的CAS循环中，每次失败后重新加载最新的prod_tail值，确保CAS使用正确的预期值：

// move prod_tail
while (true) {
    local_prod_head = prod_tail.load(); // 每次循环获取最新的prod_tail
    if (prod_tail.compare_exchange_weak(local_prod_head, local_prod_next))
        break;
}

同时可以将Push中的内存屏障改为更轻量的release语义，配合Pop的acquire语义，形成完整的release-acquire可见性链：

// 替换原有的seq_cst屏障
std::atomic_thread_fence(std::memory_order_release);

x86架构下，release语义不需要额外的指令（x86本身对写操作有store-store屏障），但显式声明语义可以保证跨平台的正确性。

内容的提问来源于stack exchange，提问作者Alex