线程同步：分离数据队列与事件队列的正确性验证

问题描述 #

我们考虑经典的生产者-消费者问题：线程A将消息放入队列Q，线程B从Q中取出消息。线程B需收到线程A的通知才能从Q取消息。假设有另一队列E，线程B在E上等待多种事件；线程A通过向E推送事件msg_from_A来通知B已向Q添加新消息。此场景适用于E非多态、无法容纳可变大小元素的情况。当B收到msg_from_A时，会查看并取出Q中的一个元素。

两个队列的访问均由互斥锁保护，线程B的逻辑如下：

while (true) {
  event = wait(E)
  switch(event){
  case "msg_from_A":
    msg = pop(Q)
    do stuff with msg ...
    break
  case "other event":
    ...
  }
}

线程A的逻辑如下：

push(msg, Q)
push("msg_from_A", E)

核心问题：该实现是否正确？能否保证消息msg先被推入Q，再将事件msg_from_A推入E？若操作顺序颠倒，会出现竞态条件：B可能在A向Q推入消息前被唤醒，导致空弹出。尽管代码按此顺序编写，但编译器或CPU是否可能对操作重排？（注：push等队列操作内部使用互斥锁，插入前获取锁，完成后释放锁）

结论与分析 #

这个实现是完全正确的，能够严格保证push(msg, Q)的执行顺序在push("msg_from_A", E)之前，不会出现你担心的重排问题，核心原因在于互斥锁的内存屏障特性：

• 互斥锁的「解锁」操作自带强内存屏障语义：解锁前的所有内存修改操作，会被强制刷入主内存并对其他线程可见；同时，编译器和CPU绝对不会将解锁后的操作重排到解锁之前，也不会把锁获取之前的操作重排到锁获取之后。
• 线程A执行push(msg, Q)时，会先获取Q的互斥锁，完成消息插入后释放锁；后续执行push("msg_from_A", E)时，会获取E的互斥锁再释放。由于Q的解锁操作会形成一道内存屏障，阻止E的锁操作被重排到Q的锁操作之前，因此这两个push的执行顺序在任何情况下都不会被颠倒。
• 从线程B的视角来看，当它收到msg_from_A事件并调用pop(Q)时，Q的互斥锁会确保它能看到线程A已经完成插入的消息，完全不会出现空弹出的竞态场景。

简言之，互斥锁的内存屏障机制已经替你屏蔽了编译器和CPU的指令重排风险，代码中编写的操作顺序就是实际执行的顺序，无需额外担心竞态问题。

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