多线程更新C++ volatile变量：线程能否及时读取最新值？

代码示例 #

volatile bool b;

// Thread1: 仅读取b
void f1() {
    while (1) {
        if (b) { /* do something */ };
        else { /* do something else */ };
    }
}

// Thread2: 仅在特定条件满足时将b设为true
void f2() {
    while (1) {
        // 评估本地条件 - local_cond
        if (!b && (local_cond == true)) b = true;
        // 其他操作
    }
}

// Thread3: 仅在收到Socket消息时将b设为false
void f3() {
    while (1) {
        // 监听Socket
        if (expected message came) b = false;
        // 其他操作
    }
}

问题 #

线程2在时间t将b设为true，线程3在t+5将b设为false，线程1能否在t+delta至t+5+delta期间读到true，之后读到false（delta为变量写入内存的耗时）？

解答 #

不能保证线程1“及时”看到b的最新值，原因如下：

• 标准C++中，volatile的设计初衷是处理硬件寄存器这类特殊内存的读写，仅能阻止编译器对变量读写的优化，强制每次访问都直接操作内存，但不提供多线程环境下的内存可见性保证。
• 现代CPU的多级缓存机制会导致缓存不一致：线程2或3写入的b值可能先存储在所在核心的私有缓存中，未同步到主内存，线程1所在核心的缓存依然保留旧值，导致读取结果滞后。
• 此外，volatile也不约束指令重排序，编译器或CPU可能调整读写指令的执行顺序，进一步破坏可见性的及时性。

正确实现方案 #

要确保多线程间变量的可见性，应使用C++标准库的std::atomic<bool>，它通过内存顺序约束保证写入操作的结果能被后续读取及时感知：

#include <atomic>
std::atomic<bool> b(false);

// Thread1: 读取b
void f1() {
    while (1) {
        if (b.load(std::memory_order_acquire)) { 
            /* do something */ 
        } else { 
            /* do something else */ 
        }
    }
}

// Thread2: 写入b为true
void f2() {
    while (1) {
        if (!b.load(std::memory_order_acquire) && local_cond) {
            b.store(true, std::memory_order_release);
        }
        // 其他操作
    }
}

// Thread3: 写入b为false
void f3() {
    while (1) {
        if (expected message came) {
            b.store(false, std::memory_order_release);
        }
        // 其他操作
    }
}

std::memory_order_acquire确保读取操作能看到之前所有已完成的写入，std::memory_order_release确保写入操作的结果对后续所有读取可见，完全满足题目中“及时看到最新值”的要求。

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