返回bool标识的Lambda表达式无法停止条件变量wait()函数问题咨询

• 条件变量不会主动检查谓词状态 #

  带谓词参数的std::condition_variable::wait接口，底层逻辑等价于以下代码：

  while (!predicate()) {
      wait(lock);
  }
  

  也就是说，只有当wait被notify唤醒、或者发生系统假唤醒时，才会执行谓词判断状态是否满足。你原代码仅修改了m_QuitReconstructionFlag退出标识，没有调用条件变量的notify方法，工作线程会一直阻塞在wait调用上，根本没有机会重新执行谓词检查，自然无法退出阻塞。

• 共享变量存在数据竞争 #

  m_QuitReconstructionFlag是跨线程访问的共享变量，你在Stop函数中直接修改该变量时，没有持有对应的互斥锁，也没有将变量定义为原子类型，属于C++标准定义的数据竞争未定义行为。受CPU缓存同步、编译器指令重排影响，工作线程可能根本感知不到退出标识的修改，哪怕被唤醒也可能读到旧值导致无法跳出循环。

你做的两处改动刚好解决了上述两个核心问题：

1. 调用notify_all()主动唤醒了阻塞在wait上的工作线程，让线程有机会继续执行后续逻辑
2. 移除lambda谓词后，wait只要被唤醒就会直接向下执行，不管退出标识状态，后续的if (m_QuitReconstructionFlag)判断自然可以生效

其实不需要移除lambda谓词，带谓词的wait可以自动处理假唤醒问题，安全性更高。只需要修改Stop逻辑即可兼容原有代码：

void WorkDispatcher::Stop()
{
    // 加锁保护共享变量修改，避免数据竞争
    std::lock_guard<std::mutex> locker(m_rgbdMutex);
    m_Reconstructor.m_QuitReconstructionFlag = true;
    // 唤醒工作线程触发谓词检查
    m_RgbConditional.notify_all();

    if (m_reconstructionThread.joinable())
        m_reconstructionThread.join();
}

也可以将m_QuitReconstructionFlag定义为std::atomic<bool>类型，不需要加锁即可保证跨线程读写的可见性，修改后仍需调用notify唤醒线程。

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