跨线程回调场景下的C++原子操作内存同步问题

代码场景 #

// 类成员
std::atomic_bool blocked = true;
int counter = 0; // 实际场景中会用 std::atomic<int>

// 线程1逻辑
while (...)
{
    counter++; // #4
    if (blocked.load(std::memory_order::acquire))
    {
        // #3
        // 执行一些操作
        event.set_callback([this]() // #1
        {
            // 回调在另一个线程执行
            blocked.store(false, std::memory_order::release); // #2
            blocked.notify_one();
        });
    }
}

// 线程2逻辑
while (...)
{
    blocked.wait(true, std::memory_order::acquire);
    if (counter > ...) 
    {
        // 基于counter的判断逻辑
    }
    blocked.store(true, std::memory_order::release);
}

背景说明 #

#1处的回调会由外部事件在另一线程触发执行，需要确保线程2能看到线程1更新后的counter正确值。目前未在C++标准中发现lambda捕获存在类似线程join()的隐式release-acquire同步机制。

核心问题 #

1. 当前代码能否满足需求？从C++内存模型来看，#2的release操作在另一线程执行，似乎不足以保证同步；但直觉上认为捕获this的lambda能看到对象的更新，如果仅捕获blocked的话情况又会如何？
2. 如果当前代码不行，能否仅用单个原子变量实现同步，不需要互斥锁？比如在#3处添加一个release存储操作是否可行？
3. 如果counter是std::atomic<int>类型，情况会怎样？用seq_cst序的fetch_add肯定可行，那acq_rel序的fetch_add能否防止它和blocked.load的重排序？

问题1：当前代码无法满足同步需求 #

从C内存模型的严格规则来看，**线程1的#4操作（counter）和回调里的#2操作（blocked.store(release)）之间没有任何同步关系**：

• lambda捕获this或blocked只是让回调能访问对象成员，但这仅保证同一线程内的可见性，跨线程的同步必须依赖显式的内存序操作或同步机制。
• 线程2的blocked.wait(acquire)只能和#2的store(release)建立同步，但由于线程1和回调线程之间没有同步链，线程1的counter更新无法保证被回调线程可见，自然也无法通过#2的同步传递给线程2。

问题2：可以用单个原子变量实现，需补全同步链 #

仅用blocked这一个原子变量就能实现同步，核心是在线程1的#3位置（设置回调前）添加一个release操作，补全线程1到回调线程的同步链路：

// 线程1的#3位置添加（即使blocked已经是true，release语义依然生效）
blocked.store(true, std::memory_order::release);

或者更高效的无修改方式：

blocked.fetch_add(0, std::memory_order::release);

同步逻辑：

• 线程1的release操作会将所有之前的内存操作（包括#4的counter++）标记为“已发布”，确保后续任何对blocked执行acquire操作的线程都能看到这些更新。
• 回调线程的#2操作（store(release)）会和线程2的blocked.wait(acquire)建立同步，线程1的counter更新会通过这条完整的同步链传递到线程2，保证可见性。

问题3：counter为atomic时的情况 #

• seq_cst序的fetch_add：由于seq_cst的全局同步特性，会强制所有线程看到统一的操作顺序，自然能保证counter的更新被线程2可见，且不会和blocked.load重排序。
• acq_rel序的fetch_add：单独使用不足以保证线程2能看到counter的更新——fetch_add(acq_rel)仅能禁止自身与前后操作的重排序，但线程1和回调线程之间依然缺少同步链。必须配合问题2中提到的线程1到回调线程的release操作，才能把counter的更新传递给线程2。

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