c++怎么使用条件变量std::condition_variable_c++线程通信与等待机制-C++-PHP中文网

c++怎么使用条件变量std::condition_variable_c++线程通信与等待机制

裘德小鎮的故事

发布： 2025-11-10 20:05:14

原创

648人浏览过

std::condition_variable用于线程同步，配合mutex和共享变量实现高效等待与通知机制，如生产者-消费者模型中通过wait()和notify_one()协调线程，避免轮询并处理虚假唤醒。

c++怎么使用条件变量std::condition_variable_c++线程通信与等待机制

在C++多线程编程中，std::condition_variable 是一种重要的同步机制，用于线程间的通信与等待。它通常配合 std::unique_lock<:mutex> 使用，实现一个线程等待某个条件成立，而另一个线程在条件达成时通知等待中的线程继续执行。

基本概念：条件变量的作用

条件变量允许线程**主动挂起**，直到接收到“条件已满足”的信号。这种机制避免了轮询检查共享状态，提高了效率和响应性。

典型使用场景包括：

生产者-消费者模型
任务队列的空/满状态控制
等待某个资源初始化完成

关键组件与用法步骤

使用 std::condition_variable 需要三个核心部分：

立即学习“C++免费学习笔记（深入）”；

微信 WeLM

WeLM不是一个直接的对话机器人，而是一个补全用户输入信息的生成模型。

查看详情

std::condition_variable 实例：用于阻塞和唤醒线程
std::mutex 和 std::unique_lock：保护共享数据并配合条件变量使用
一个表示条件的共享变量（如布尔值、队列是否为空等）

标准使用流程如下：

等待线程获取互斥锁，然后调用 wait() 方法，并传入锁和一个判断条件的谓词
条件变量会自动释放锁，使其他线程可以修改共享状态
当其他线程修改状态后，调用 notify_one() 或 notify_all() 唤醒等待线程
被唤醒的线程重新获取锁，并再次检查条件是否满足

代码示例：生产者-消费者模型

下面是一个简单的例子，展示两个线程通过条件变量协作：

#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 < 5; ++i) {
        std::this_thread::sleep_for(std::chrono::milliseconds(100));
        std::unique_lock<std::mutex> lock(mtx);
        data_queue.push(i);
        std::cout << "生产: " << i << "\n";
        lock.unlock();
        cv.notify_one(); // 通知消费者
    }
    {
        std::unique_lock<std::mutex> lock(mtx);
        finished = true;
    }
    cv.notify_one(); // 通知消费者生产结束
}

void consumer() {
    while (true) {
        std::unique_lock<std::mutex> lock(mtx);
        // 等待队列非空或生产结束
        cv.wait(lock, [] { return !data_queue.empty() || finished; });

        if (!data_queue.empty()) {
            int value = data_queue.front();
            data_queue.pop();
            std::cout << "消费: " << value << "\n";
        }

        if (data_queue.empty() && finished) {
            break; // 结束循环
        }
        lock.unlock();
    }
    std::cout << "消费者退出\n";
}

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

    p.join();
    c.join();

    return 0;
}

登录后复制

说明：