Visual C++2017中std::condition_variable::wait_for随机异常返回问题咨询

这可不是Visual C++ 2017的bug，而是你忽略了C++多线程同步里一个很常见的现象——虚假唤醒（spurious wakeup）。

什么是虚假唤醒？ #

简单来说，即使你没有调用notify_one()或notify_all()来唤醒条件变量，操作系统也可能因为底层的线程调度或性能优化原因，让wait_for()提前返回。这种情况是POSIX和Windows线程库都允许的行为，C++标准也明确认可了这一点。

你的代码问题就出在：直接依赖wait_for()的返回值判断是否被通知，但没有做任何实际的条件检查。一旦遇到虚假唤醒，wait_for()就会返回cv_status::no_timeout，但这根本不是你期望的“被通知”场景。

怎么修复？ #

正确使用std::condition_variable的方式，是永远配合条件检查——要么用带谓词的重载版本，要么在wait_for()返回后手动验证你关心的条件。

场景1：仅需定时等待（无实际通知需求）

可以添加一个永远为false的谓词，这样虚假唤醒会自动让线程重新进入等待，直到超时：

#include <condition_variable>
#include <mutex>
#include <thread>
#include <chrono>
#include <cstdio>
#include <windows.h>

std::condition_variable m_cv;
std::mutex m_mutex;

void ThreadProc() {
    while (1) {
        std::unique_lock<std::mutex> lk(m_mutex);
        // 用谓词确保只有超时才会返回，虚假唤醒会自动重新等待
        std::cv_status r = m_cv.wait_for(lk, std::chrono::milliseconds(200), []{ return false; });
        
        printf("Result %s\n", r == std::cv_status::timeout ? "timeout" : "no timeout");
        lk.unlock();
        Sleep(100);
    }
}

int _tmain(int argc, _TCHAR* argv[]) {
    std::thread th(ThreadProc);
    th.join();
    return 0;
}

场景2：等待具体条件（如任务完成）

用一个标志变量配合，确保只有当实际条件满足时才会跳出等待：

#include <condition_variable>
#include <mutex>
#include <thread>
#include <chrono>
#include <cstdio>
#include <windows.h>

std::condition_variable m_cv;
std::mutex m_mutex;
bool task_done = false; // 实际要等待的条件标志

void ThreadProc() {
    while (1) {
        std::unique_lock<std::mutex> lk(m_mutex);
        // 等待直到任务完成或者超时
        std::cv_status r = m_cv.wait_for(lk, std::chrono::milliseconds(200), []{ return task_done; });
        
        if (r == std::cv_status::timeout) {
            printf("Result timeout\n");
        } else {
            printf("Result no timeout\n");
            task_done = false; // 重置标志，等待下一次任务
        }
        lk.unlock();
        Sleep(100);
    }
}

// 如需触发通知可在主线程中添加：
// std::lock_guard<std::mutex> lk(m_mutex);
// task_done = true;
// m_cv.notify_one();

int _tmain(int argc, _TCHAR* argv[]) {
    std::thread th(ThreadProc);
    th.join();
    return 0;
}

总结 #

• 虚假唤醒是正常现象，不是编译器bug；
• 永远不要单独使用wait()/wait_for()/wait_until()，一定要配合条件检查（谓词或手动判断）；
• 带谓词的重载版本会自动处理虚假唤醒：每次唤醒后都会检查谓词，如果不满足就重新进入等待。

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