std::condition_variable需与std::mutex和std::unique_lock配合使用，通过wait()、notify_one()、notify_all()实现线程同步，在生产者-消费者模型中确保数据安全访问与线程正确唤醒。
在C++多线程编程中，std::condition_variable 是实现线程间同步的重要工具之一。它通常与 std::mutex 配合使用，用于让一个或多个线程等待某个条件成立，而另一个线程在条件满足时通知等待的线程继续执行。
基本概念与头文件
要使用条件变量，需包含头文件：
#include核心组件包括：
- std::condition_variable：条件变量对象，用于阻塞线程或唤醒其他线程。
- std::unique_lock<:mutex>：必须使用 unique_lock，因为 condition_variable 的 wait 操作需要能释放和重新获取锁。
- wait()、notify_one()、notify_all()：主要成员函数。
典型使用模式：生产者-消费者模型
下面是一个简单的生产者-消费者示例，展示如何用 std::condition_variable 实现线程同步。
立即学习“C++免费学习笔记（深入）”；
#include iostream>#include
#include
#include
#include
std::queue
std::mutex mtx;
std::condition_variable cv;
bool finished = false;
void producer() {
for (int i = 0; i std::unique_lock<:mutex> lock(mtx);
data_queue.push(i);
lock.unlock();
cv.notify_one(); // 唤醒一个消费者
std::this_thread::sleep_for(std::chrono::milliseconds(100));
}
{
std::unique_lock<:mutex> 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 } else if (finished) {
lock.unlock();
break; // 结束循环
}
}
std::cout }
主函数启动线程：
int main() {
std::thread p(producer);
std::thread c1(consumer);
std::thread c2(consumer);
p.join();
c1.join();
c2.join();
return 0;
}
关键点说明
wait() 的正确使用方式
- 调用 wait 时，会自动释放锁，并使线程进入阻塞状态。
- 当被 notify 唤醒后，线程会重新获取锁，再继续执行。
- 推荐使用带谓词的 wait 形式：
cv.wait(lock, predicate)
，避免虚假唤醒导致的问题。
notify_one vs notify_all
- notify_one：唤醒一个等待线程，适用于只有一个线程需要处理任务的场景（如单个消费者）。
- notify_all：唤醒所有等待线程，适合广播事件或多个消费者竞争的情况。
为什么必须用 unique_lock？
因为 condition_variable 在 wait 过程中需要临时释放互斥量，并在唤醒后重新加锁，只有 unique_lock 支持这种灵活的锁定控制。
注意事项与常见陷阱
- 确保共享数据访问始终受 mutex 保护。
- 避免忘记调用 notify，否则等待线程可能永远阻塞。
- 注意 finished 标志也需要在锁内修改，保证可见性。
- 多个消费者时，检查队列是否为空必须在锁内完成。
基本上就这些。std::condition_variable 虽然强大，但需小心使用锁和通知机制，确保逻辑正确、无死锁、无竞态条件。
