信息发布→ 登录 注册 退出

C++怎么使用条件变量condition_variable_C++线程同步与condition_variable使用

发布时间:2025-11-15

点击量:
condition_variable用于线程同步,配合mutex实现等待-通知机制。线程调用wait阻塞自身,直到其他线程调用notify_one或notify_all唤醒;因存在虚假唤醒,需在循环中检查条件谓词。典型步骤包括:定义condition_variable、mutex和共享条件变量;等待线程使用unique_lock加锁并调用wait等待条件满足;通知线程修改条件后调用notify唤醒等待线程。示例为生产者-消费者模型:生产者向队列添加数据并通知,消费者等待队列非空后消费,生产结束后设置finished标志并通知退出。关键点:wait的谓词参数防止虚假唤醒;notify无需持锁但应在修改共享数据后调用以保证可见性;notify_one适用于单线程唤醒,notify_all用于广播但有性能开销。正确使用可避免忙等待,提升效率。

在C++多线程编程中,condition_variable 是实现线程间同步的重要工具之一。它通常与 std::mutex 配合使用,用于在线程之间传递状态变化的通知,比如一个线程等待某个条件成立,另一个线程在完成任务后通知等待的线程继续执行。

condition_variable 的基本原理

condition_variable 本身不保存状态,它只是一个等待和唤醒机制。线程通过调用 wait() 方法阻塞自己,直到其他线程调用 notify_one()notify_all() 来唤醒它。由于条件可能被虚假唤醒(spurious wakeup),所以等待时必须配合一个循环检查实际条件是否满足。

标准做法是使用 std::unique_lock<:mutex> 作为锁对象传入 wait 函数,因为 wait 会自动释放锁并在被唤醒后重新获取锁,避免死锁或竞争。

基本使用步骤

  • 定义一个 condition_variable 变量和一个 mutex 变量
  • 定义一个共享的条件标志(如 bool 值)来表示事件是否发生
  • 等待线程获取锁,然后在循环中调用 wait(),直到条件满足
  • 通知线程修改条件,释放锁后调用 notify_one() 或 notify_all()

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

下面是一个简单的例子,演示两个线程如何通过 condition_variable 同步:

#include 
#include 
#include 
#include 
#include 

std::queue 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> lock(mtx);
        data_queue.push(i);
        std::cout << "Produced: " << i << std::endl;
        lock.unlock();
        cv.notify_one(); // 通知消费者
    }

    {
        std::lock_guard lock(mtx);
        finished = true;
    }
    cv.notify_one(); // 通知消费者生产结束
}

void consumer() {
    while (true) {
        std::unique_lock lock(mtx);

        // 等待队列非空或生产结束
        cv.wait(lock, [] { 
            return !data_queue.empty() || finished; 
        });

        if (!data_queue.empty()) {
            int value = data_queue.front();
            data_queue.pop();
            std::cout << "Consumed: " << value << std::endl;
        }

        if (data_queue.empty() && finished) {
            std::cout << "Consumer exiting." << std::endl;
            break;
        }

        lock.unlock();
    }
}

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

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

    return 0;
}

关键点说明

wait() 的第二个参数是谓词(predicate),这是推荐写法。它等价于:

```cpp while (!pred()) { wait(lock); } ```

这样可以防止虚假唤醒导致逻辑错误。

notify_one() 唤醒一个等待线程,适合一对一通信;notify_all() 唤醒所有等待线程,适用于广播场景,但可能带来性能开销。

注意:notify 操作不需要持有锁,但为了确保可见性,通常在修改共享数据并释放锁之后调用。

基本上就这些。合理使用 condition_variable 能有效协调线程执行顺序,避免忙等待,提升程序效率和响应性。

标签:# 对象  # 完成任务  # 应在  # 第二个  # 并在  # 不需要  # 见性  # 这是  # 死锁  # 适用于  # 是一个  # 事件  # 工具  # 多线程  # 线程  # 循环  # bool  # while  # 有锁  # red  # stream  # ios  # c++  # ai  
在线客服
服务热线

服务热线

4008888355

微信咨询
二维码
返回顶部
×二维码

截屏,微信识别二维码

打开微信

微信号已复制,请打开微信添加咨询详情!