C++如何使用条件变量(condition_variable)_C++ 条件变量使用方法-C++-PHP中文网

条件变量需与互斥锁配合使用，通过wait()在循环中检查条件防止虚假唤醒，notify_one()或notify_all()唤醒等待线程，如生产者-消费者模型中保护共享队列并通知状态变化。

c++如何使用条件变量(condition_variable)_c++ 条件变量使用方法

在C++多线程编程中，条件变量（std::condition_variable）是实现线程间同步的重要工具。它通常与互斥锁（std::mutex）配合使用，用于让一个或多个线程等待某个特定条件成立后再继续执行。

1. 条件变量的基本组成

使用 std::condition_variable 需要包含头文件 <condition_variable></condition_variable>，并配合以下组件：

std::condition_variable：条件变量对象，用于阻塞和唤醒线程。
std::mutex 和 std::unique_lock<:mutex>：保护共享数据，并在等待时临时释放锁。
wait()、notify_one()、notify_all()：核心操作函数。

2. 等待条件：wait() 的正确用法

调用 wait() 会阻塞当前线程，直到其他线程通过 notify_one() 或 notify_all() 唤醒它。注意：必须在循环中检查条件，防止虚假唤醒。

std::mutex mtx;
std::condition_variable cv;
bool ready = false;

// 等待线程
std::unique_lock<:mutex> lock(mtx);
cv.wait(lock, []{ return ready; }); // 循环检查 ready 是否为 true
</:mutex>

上面的 lambda 表达式是谓词（predicate），wait() 内部会持续检查该条件，只有当条件满足时才真正返回。

3. 唤醒线程：notify_one() 与 notify_all()

当某个线程改变了共享状态（如设置 ready = true），应通知等待中的线程：

ApiPost接口调试与文档生成工具

ApiPost是一个支持团队协作，支持模拟POST、GET、PUT等常见请求，并可直接生成文档的API调试、管理工具，ApiPost是后台接口开发者或前端、接口测试人员的工作必备工具。快速生成、一键导出API文档。感兴趣的朋友快来下载吧。软件说明ApiPost官方版是一款十分出色的接口调试与文档生成工具，ApiPost官方版界面美观大方，功能强劲实用，支持团队协作，支持模拟POST、GET、PUT等常见请求，是后台接口开发者或前端、接口测试人员的工作必备工具。软件特色更方便支持接口调试的同时快速生成、一键

下载

{
    std::lock_guard<:mutex> lock(mtx);
    ready = true;
}
cv.notify_one();   // 唤醒一个等待线程
// 或 cv.notify_all(); // 唤醒所有等待线程
</:mutex>

注意：修改共享数据时需加锁，notify_* 可在解锁后调用，但建议确保数据可见性。

4. 完整示例：生产者-消费者模型

下面是一个典型的使用场景：

#include <iostream>
#include <thread>
#include <queue>
#include <mutex>
#include <condition_variable>

std::queue<int> data_queue;
std::mutex mtx;
std::condition_variable cv;
bool finished = false;

void producer() {
    for (int i = 0; i  lock(mtx);
        data_queue.push(i);
        std::cout  lock(mtx);
        finished = true;
    }
    cv.notify_all(); // 通知所有消费者任务完成
}

void consumer() {
    while (true) {
        std::unique_lock<:mutex> lock(mtx);
        cv.wait(lock, [] { 
            return !data_queue.empty() || finished; 
        });

        if (!data_queue.empty()) {
            int value = data_queue.front();
            data_queue.pop();
            lock.unlock(); // 提前解锁，避免影响其他操作
            std::cout 
</:mutex></int></condition_variable></mutex></queue></thread></iostream>

主函数中启动线程即可看到输出：

int main() {
    std::thread p(producer);
    std::thread c1(consumer);
    std::thread c2(consumer);

    p.join();
    c1.join();
    c2.join();
    return 0;
}

基本上就这些。关键是理解：条件变量不保存状态，只负责“通知”，实际条件判断依赖共享变量和谓词检查。用好 wait() + 谓词 + notify 组合，就能安全实现线程同步。