c++中如何实现生产者消费者模型_c++生产者消费者模型实现方法

裘德小鎮的故事

发布时间：2025-10-11 21:27:01

717人浏览过

来源于php中文网

原创

答案：C++中生产者消费者模型通过std::mutex和std::condition_variable实现线程同步，使用队列作为共享缓冲区，生产者添加数据后通知消费者，消费者等待数据就绪，避免竞争条件；可通过条件变量控制缓冲区满或空的状态，或在C++20中使用std::counting_semaphore简化同步逻辑。

c++中如何实现生产者消费者模型_c++生产者消费者模型实现方法

在C++中实现生产者消费者模型，核心是让多个线程安全地共享一个缓冲区：生产者往里放数据，消费者从中取数据。关键在于解决线程间的同步与互斥问题，避免竞争条件和资源冲突。

使用std::queue + std::mutex + std::condition_variable

这是现代C++中最推荐的方式，利用标准库提供的工具实现高效同步。

基本思路： 用一个队列作为共享缓冲区，互斥锁（mutex）保护对队列的访问，条件变量（condition variable）用于阻塞和唤醒线程。

生产者线程在添加数据前获取锁，添加后通知消费者
消费者线程在队列为空时等待条件变量，收到通知后再尝试取数据
通过条件变量避免忙等待，提高效率

示例代码：

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

#include 
#include 
#include 
#include 
#include 
std::queue buffer;
std::mutex mtx;
std::condition_variable cv;
bool finished = false;
const int max_items = 10;
void producer(int id) {
for (int i = 0; i < max_items; ++i) {
std::this_thread::sleep_for(std::chrono::milliseconds(100));
std::unique_lock lock(mtx);
buffer.push(i);
std::cout << "Producer " << id << " produced: " << i << "\n";
lock.unlock();
cv.notify_one();
}
}
void consumer(int id) {
while (true) {
std::unique_lock lock(mtx);
cv.wait(lock, []{ return !buffer.empty() || finished; });
if (!buffer.empty()) {
int value = buffer.front();
buffer.pop();
std::cout << "Consumer " << id << " consumed: " << value << "\n";
if (value == max_items - 1) {
finished = true;
cv.notify_all();
}
} else if (finished) {
break;
}
lock.unlock();
}
}

限制缓冲区大小的改进版本

真实场景中缓冲区通常有容量限制，需同时判断“是否满”和“是否空”。

生产者在缓冲区满时等待
消费者在缓冲区空时等待
两个条件可用同一个条件变量或两个分别控制

修改点：

Bandy AI

全球领先的电商设计Agent

下载

const int capacity = 5;
// 生产者中增加判断：
cv.wait(lock, []{ return buffer.size() < capacity; });
// 消费者中判断非空：
cv.wait(lock, []{ return buffer.size() > 0; });

使用信号量模拟（C++20前需自定义）

C++标准库没有原生信号量，但可以用condition_variable模拟。

或者在支持C++20的环境中使用std::counting_semaphore，更简洁。

#include 
std::counting_semaphore<10> sem_fill(0);   // 已填充槽位
std::counting_semaphore<10> sem_empty(10); // 空槽位
// 生产者：
sem_empty.acquire(); // 占用一个空位
buffer.push(data);
sem_fill.release();  // 增加一个填充位
// 消费者：
sem_fill.acquire();  // 等待有数据
data = buffer.pop();
sem_empty.release(); // 释放一个空位

注意事项与最佳实践

实现时注意以下几点以避免常见问题：

条件变量必须配合unique_lock使用
wait调用要放在循环中检查条件，防止虚假唤醒
notify_one()唤醒一个等待线程，notify_all()唤醒全部（适合多消费者）
尽量减少锁的持有时间，只保护真正共享的数据操作
设置合理的退出机制，避免线程无法结束

基本上就这些。使用标准库组件能写出清晰、安全、高效的生产者消费者模型。关键是理解mutex保护数据，condition_variable协调执行时机。不复杂但容易忽略细节。

c++如何捕获异常_c++ try catch异常处理【教程】

C++ 宏定义和枚举区别 C++ define与enum使用场景对比【语法】

C++ 内存泄漏怎么检测 C++ Visual Studio内置CRT调试工具【调试】

c++如何实现命令模式 c++设计模式之Command【实例】

c++中如何实现线程池_c++高性能线程池任务队列实现步骤【实例】

c++速学教程(入门到精通)

c++怎么学习？c++怎么入门？c++在哪学？c++怎么学才快？不用担心，这里为大家提供了c++速学教程(入门到精通)，有需要的小伙伴保存下载就能学习啦！

下载

相关标签:

工具 ai c++ ios stream 常见问题标准库循环线程

本站声明：本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn

上一篇：c++怎么获取当前函数名和行号_c++函数名与行号获取方法下一篇：c++中的std::unordered_map和std::map的差异_c++ unordered_map与map比较

作者最新文章

Composer怎么发布自己的包提交代码到Packagist流程【分享】

2026-01-26 14:07

Linux如何查看网络流量_Linux流量监控工具nload与iftop【教程】

2026-01-26 14:08

转转app怎么关闭个性化推荐转转app隐私设置在哪里【建议】

2026-01-26 14:08

漫蛙备用网址入口2026 漫蛙网页版在线浏览指南

2026-01-26 14:08

C++ future和promise C++ 异步编程结果传递【并发编程】

2026-01-26 14:14

Yandex官网镜像入口_俄罗斯Yandex搜索引擎网页版在线

2026-01-26 14:15

tplogin.cn管理页面 tplink无线路由器官网

2026-01-26 14:15

Win11怎么查看系统日志 Win11事件查看器使用教程【故障】

2026-01-26 14:16

Mac怎么使用听写功能 Mac语音输入文字设置方法【妙招】

2026-01-26 14:18

AO3有效网址链接_Archive of Our Own官方通道

2026-01-26 14:18

热门AI工具

DeepSeek

幻方量化公司旗下的开源大模型平台

AI 编程开发 AI 聊天问答

豆包大模型

字节跳动自主研发的一系列大型语言模型

AI 编程开发 AI大模型

通义千问

阿里巴巴推出的全能AI助手

AI 编程开发 Agent智能体

腾讯元宝

腾讯混元平台推出的AI助手

文档处理 AI 聊天问答

文心一言

文心一言是百度开发的AI聊天机器人，通过对话可以生成各种形式的内容。

AI 编程开发 AI 文本写作

讯飞写作

基于讯飞星火大模型的AI写作工具，可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

AI 文本写作中文写作

即梦AI

一站式AI创作平台，免费AI图片和视频生成。

图片拼接图画生成

ChatGPT

最最强大的AI聊天机器人程序，ChatGPT不单是聊天机器人，还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

AI 编程开发 AI 文本写作

智谱清言 - 免费全能的AI助手

AI 编程开发 Agent智能体

相关专题

线程和进程的区别

线程和进程的区别：线程是进程的一部分，用于实现并发和并行操作，而线程共享进程的资源，通信更方便快捷，切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

503

2023.08.10

俄罗斯Yandex引擎入口

2026年俄罗斯Yandex搜索引擎最新入口汇总，涵盖免登录、多语言支持、无广告视频播放及本地化服务等核心功能。阅读专题下面的文章了解更多详细内容。

177

2026.01.28

包子漫画在线官方入口大全

本合集汇总了包子漫画2026最新官方在线观看入口，涵盖备用域名、正版无广告链接及多端适配地址，助你畅享12700+高清漫画资源。阅读专题下面的文章了解更多详细内容。

2026.01.28

ao3中文版官网地址大全

AO3最新中文版官网入口合集，汇总2026年主站及国内优化镜像链接，支持简体中文界面、无广告阅读与多设备同步。阅读专题下面的文章了解更多详细内容。

2026.01.28

php怎么写接口教程

本合集涵盖PHP接口开发基础、RESTful API设计、数据交互与安全处理等实用教程，助你快速掌握PHP接口编写技巧。阅读专题下面的文章了解更多详细内容。

2026.01.28

php中文乱码如何解决

本文整理了php中文乱码如何解决及解决方法,阅读节专题下面的文章了解更多详细内容。

2026.01.28

Java 消息队列与异步架构实战

本专题系统讲解 Java 在消息队列与异步系统架构中的核心应用，涵盖消息队列基本原理、Kafka 与 RabbitMQ 的使用场景对比、生产者与消费者模型、消息可靠性与顺序性保障、重复消费与幂等处理，以及在高并发系统中的异步解耦设计。通过实战案例，帮助学习者掌握使用 Java 构建高吞吐、高可靠异步消息系统的完整思路。

2026.01.28

Python 自然语言处理（NLP）基础与实战

本专题系统讲解 Python 在自然语言处理（NLP）领域的基础方法与实战应用，涵盖文本预处理（分词、去停用词）、词性标注、命名实体识别、关键词提取、情感分析，以及常用 NLP 库（NLTK、spaCy）的核心用法。通过真实文本案例，帮助学习者掌握使用 Python 进行文本分析与语言数据处理的完整流程，适用于内容分析、舆情监测与智能文本应用场景。

2026.01.27