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 使用,不能用 lock_guard。 调用 wait 时会自动释放锁,并在被唤醒后重新获取锁。 建议使用带谓词的 wait 形式,防止虚假唤醒(spurious wakeup)导致错误行为。
基本用法示例:生产者-消费者模型
下面是一个典型的使用 condition_variable 实现生产者-消费者问题的例子:
立即学习“C++免费学习笔记(深入)”;
#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 的使用模式,能让你写出更稳定、高效的并发程序。重点是理解“等待-通知”机制的本质,以及如何安全地操作共享数据。
以上就是C++ condition_variable条件变量用法_C++线程间通信实战的详细内容,更多请关注创想鸟其它相关文章!
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1489816.html
微信扫一扫
支付宝扫一扫