c++中条件变量condition_variable怎么用_condition_variable实现线程同步-C++-PHP中文网

c++中条件变量condition_variable怎么用_condition_variable实现线程同步

尼克

发布： 2025-10-09 14:00:07

原创

941人浏览过

std::condition_variable需与std::mutex配合使用，通过wait、notify_one、notify_all实现线程同步，在生产者-消费者模型中避免虚假唤醒并高效协作。

c++中条件变量condition_variable怎么用_condition_variable实现线程同步

在C++中，std::condition_variable 是实现线程同步的重要工具之一，常用于线程间的协作。它通常与 std::mutex 配合使用，用来阻塞一个或多个线程，直到某个条件成立才被唤醒。

condition_variable 的基本用法

condition_variable 本身不能独立使用，必须和互斥锁（std::unique_lock<:mutex>）一起工作。主要成员函数包括：

wait(lock, predicate)：释放锁并等待被通知。当被唤醒时，重新获取锁并检查条件（predicate）。如果条件不满足，继续等待。
notify_one()：唤醒一个正在等待的线程。
notify_all()：唤醒所有等待的线程。

典型场景是“生产者-消费者”模型，下面是一个简单示例：

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

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";
}

登录后复制

在 main 函数中启动线程：

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

商汤商量

商汤科技研发的AI对话工具，商量商量，都能解决。

查看详情

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

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

    return 0;
}

登录后复制