condition_variable用于线程间通信，需与std::mutex配合使用，通过wait()阻塞线程、notify_one()/notify_all()唤醒线程，避免忙等待。使用时应结合谓词防止虚假唤醒，确保在循环中检查条件，并在修改共享状态后正确调用notify。典型应用于生产者-消费者模型，保证多线程下数据安全与效率。
在C++多线程编程中，condition_variable 是实现线程间通信的重要工具之一。它通常与 std::mutex 配合使用，用于在线程之间传递状态变化的通知，避免忙等待（busy-waiting），提高程序效率和响应性。
condition_variable 基本原理
condition_variable 本身不存储状态，它依赖于一个外部的条件变量（通常是布尔值或枚举等）来判断是否满足唤醒条件。当某个线程发现条件未满足时，它可以调用 wait() 函数将自己阻塞；而另一个线程在改变共享状态后，通过调用 notify_one() 或 notify_all() 来唤醒一个或所有等待中的线程。
关键点：
- 必须配合 std::unique_lock<:mutex> 使用，不能用 lock_guard。
- 调用 wait 时会自动释放锁，并在被唤醒后重新获取锁。
- 建议使用带谓词的 wait 形式，防止虚假唤醒（spurious wakeup）导致错误行为。
基本用法示例：生产者-消费者模型
下面是一个典型的使用 condition_variable 实现生产者-消费者问题的例子：
#include
#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(500));
std::unique_lock lock(mtx);
data_queue.push(i);
lock.unlock();
cv.notify_one(); // 通知消费者
std::cout << "Produced: " << i << "\n";
}
// 生产结束
std::unique_lock lock(mtx);
finished = true;
lock.unlock();
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();
lock.unlock();
std::cout << "Consumed: " << value << "\n";
} else if (finished) {
break; // 无数据且已结束
}
}
std::cout << "Consumer finished.\n";
}
主函数启动两个线程：
int main() {
std::thread c(consumer);
std::thread p(producer);
c.join();
p.join();
return 0;
}
输出类似：
Produced: 0
Consumed: 0
Produced: 1
Consumed: 1
...
Consumer finished.
常见注意事项和技巧
使用 condition_variable 时有几个关键细节需要注意：
-
始终在循环中检查条件：即使被唤醒，也不能保证条件真正满足，因为存在虚假唤醒。
-
及时释放锁：处理完共享数据后尽快解锁，避免阻塞其他线程。
-
notify 的时机要正确：确保在修改共享状态并释放锁之后再调用 notify，否则可能错过信号。
-
避免死锁：多个线程竞争同一资源时，注意加锁顺序和范围。
- 可以用 notify_all() 唤醒所有等待线程，适用于广播场景，但要注意性能开销。
替代方案与选择建议
除了 condition_variable，C++ 还有其他线程同步机制：
-
std::future / std::promise：适合一次性结果传递，比如异步任务完成通知。
-
信号量（需自行实现或使用第三方库）：支持更复杂的资源计数控制。
-
原子变量 + 自旋锁：适用于低延迟场景，但可能浪费CPU。
对于需要等待某个条件成立的场景，condition_variable 仍然是最常用、最高效的选择。
基本上就这些。掌握好 condition_variable 的使用模式，能让你写出更稳定、高效的并发程序。重点是理解“等待-通知”机制的本质，以及如何安全地操作共享数据。
cv.notify_one(); // 通知消费者
std::cout << "Produced: " << i << "\n";
}
// 生产结束
std::unique_lock