生产者消费者模式通过共享缓冲区、互斥锁和条件变量实现多线程同步,解决数据生产与消费速度不匹配问题,C++中利用queue、mutex和condition_variable完成线程间协调,确保线程安全与高效通信。

生产者消费者模式是多线程编程中的经典问题,用于解决生产数据与消费数据速度不匹配的问题。在C++中,通常使用互斥锁(std::mutex)、条件变量(std::condition_variable)和队列(std::queue)来实现线程间的同步与互斥。
核心组件说明
要实现生产者消费者模型,需要以下几个关键元素:
共享缓冲区:通常是一个队列,用于暂存生产者生成的数据,供消费者取出处理。 互斥锁(mutex):保护共享资源,防止多个线程同时访问导致数据竞争。 条件变量(condition_variable):用于线程间通信,当缓冲区为空时让消费者等待,当缓冲区有数据时通知消费者;当缓冲区满时让生产者等待,有空间时通知生产者。
代码实现示例
下面是一个基于固定大小缓冲区的生产者消费者模型实现:
#include #include #include #include #include #include std::queue buffer;std::mutex mtx;std::condition_variable not_empty;std::condition_variable not_full;const int max_buffer_size = 5;void producer(int id) { for (int i = 0; i < 10; ++i) { std::unique_lock lock(mtx); not_full.wait(lock, []() { return buffer.size() < max_buffer_size; }); buffer.push(i); std::cout << "生产者 " << id << " 生产: " << i << std::endl; not_empty.notify_one(); std::this_thread::sleep_for(std::chrono::milliseconds(100)); }}void consumer(int id) { for (int i = 0; i < 10; ++i) { std::unique_lock lock(mtx); not_empty.wait(lock, []() { return !buffer.empty(); }); int value = buffer.front(); buffer.pop(); std::cout << "消费者 " << id << " 消费: " << value << std::endl; not_full.notify_one(); std::this_thread::sleep_for(std::chrono::milliseconds(150)); }}
主函数中启动多个生产者和消费者线程:
立即学习“C++免费学习笔记(深入)”;
int main() { std::thread p1(producer, 1); std::thread p2(producer, 2); std::thread c1(consumer, 1); std::thread c2(consumer, 2); p1.join(); p2.join(); c1.join(); c2.join(); return 0;}
关键点解析
该实现中几个重要细节:
使用 std::unique_lock 配合条件变量,支持在等待时释放锁,并在被唤醒后重新获取。 条件变量的 wait 方法接受一个谓词(lambda表达式),避免虚假唤醒问题。 每次修改缓冲区后调用 notify_one() 唤醒一个等待线程,也可以使用 notify_all() 唤醒所有等待线程。 通过 std::this_thread::sleep_for 模拟生产/消费耗时,使输出更清晰。
应用场景与扩展
这种模式广泛应用于任务调度、消息队列、日志处理等场景。可以根据需求进行扩展:
使用循环队列或智能指针管理对象生命周期。 添加停止信号(如标志位)优雅关闭线程。 使用 std::shared_mutex 实现读写优化(若允许多个消费者同时读)。 封装成模板类,支持不同类型的数据。
基本上就这些。掌握这个模型对理解多线程同步机制非常有帮助。
以上就是C++如何实现生产者消费者模式_C++多线程同步与互斥经典案例的详细内容,更多请关注创想鸟其它相关文章!
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1486337.html
微信扫一扫
支付宝扫一扫