c++怎么使用条件变量condition_variable_条件变量使用详解-C++-PHP中文网

c++怎么使用条件变量condition_variable_条件变量使用详解

冰火之心

发布： 2025-09-29 15:51:02

原创

459人浏览过

条件变量是C++中用于线程同步的机制，配合互斥锁实现线程间通信。它通过wait、notify_one、notify_all方法协调线程，避免忙等。在生产者-消费者示例中，生产者入队数据后通知消费者，消费者在条件不满足时等待，被唤醒后检查队列是否非空或结束标志。使用lambda谓词防止虚假唤醒，必须用unique_lock以支持锁的释放与重获。notify_one唤醒一个等待线程，适用于单任务处理；notify_all唤醒所有线程，确保多个消费者能响应状态变化。关键注意事项包括：必须在锁保护下修改共享数据、及时调用notify避免死等、防止析构时仍有线程等待。正确使用条件变量可提升多线程程序效率与安全性。

c++怎么使用条件变量condition_variable_条件变量使用详解

在C++多线程编程中，condition_variable 是一个非常重要的同步机制，常用于线程间的通信。它通常配合 std::mutex 使用，用来阻塞一个或多个线程，直到某个条件成立才被唤醒。

什么是条件变量？

条件变量（condition_variable）是标准库中的一个类，定义在 condition_variable 头文件中。它的主要作用是允许线程在某个条件不满足时进入等待状态，直到其他线程修改了共享数据并通知它。

使用条件变量可以避免忙等（busy-waiting），提高程序效率和响应性。

基本用法：wait、notify_one、notify_all

条件变量的核心方法有三个：

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

wait(lock, predicate)：线程在条件不满足时挂起，释放锁；当被唤醒后重新获取锁并检查条件。
notify_one()：唤醒一个正在等待的线程。
notify_all()：唤醒所有等待的线程。

下面是一个典型的生产者-消费者模型示例，展示如何使用条件变量：

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

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_all(); // 通知所有消费者结束
}

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 c1(consumer);
    std::thread c2(consumer);

    p.join();
    c1.join();
    c2.join();

    return 0;
}

登录后复制