C++怎么实现生产者消费者模型_C++多线程并发模型与生产者消费者实现

生产者消费者模型通过互斥锁和条件变量实现线程安全的缓冲区共享,生产者在缓冲区未满时添加数据,消费者在非空时取出数据,配合谓词等待避免虚假唤醒,使用notify_one提升效率,可通过结束标志正常退出线程。

c++怎么实现生产者消费者模型_c++多线程并发模型与生产者消费者实现

生产者消费者模型是多线程编程中的经典问题,用于描述多个线程之间如何安全地共享有限缓冲区的数据。C++中可以通过标准库的多线程支持(、、)高效实现该模型。

使用互斥锁和条件变量实现生产者消费者

核心组件包括一个共享缓冲区、互斥锁保护数据访问、两个条件变量分别通知“有空位”和“有数据”。生产者在缓冲区未满时添加数据,消费者在缓冲区非空时取出数据。

以下是一个基于固定大小队列的实现示例:

#include #include #include #include #include #include std::queue buffer;std::mutex mtx;std::condition_variable not_full;std::condition_variable not_empty;const int max_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_size; });        buffer.push(i);        std::cout << "Producer " << id << " produced: " << i << "n";        lock.unlock();        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 << "Consumer " << id << " consumed: " << value << "n";        lock.unlock();        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;}

关键机制说明

条件变量等待必须配合谓词使用:避免虚假唤醒导致逻辑错误。例如 not_full.wait(lock, [](){ return buffer.size() 确保只有真正满足条件时才继续执行。

notify_one 与 notify_all 的选择:若只有一个等待线程需被唤醒,用 notify_one 更高效;若存在多个同类等待者,根据场景决定是否广播。

解锁后通知:先释放锁再调用 notify 可减少唤醒后立即阻塞的概率,提升性能。

可改进方向

使用智能指针或自定义消息结构传递复杂数据引入结束标志位,使消费者在生产完成后续正常退出采用循环缓冲区或双缓冲技术提升吞吐量使用 std::atomic 标记运行状态,避免强制终止线程

加入结束控制的简单方式是在共享区域添加:

bool done = false;// 消费者中检测not_empty.wait(lock, []() { return !buffer.empty() || done; });if (done && buffer.empty()) break;

基本上就这些。C++11以后的标准库已足够支撑健壮的生产者消费者模型,关键是正确使用锁和条件变量组合,确保线程安全与响应性。

以上就是C++怎么实现生产者消费者模型_C++多线程并发模型与生产者消费者实现的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1488132.html

赞 (0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
c++ 运算符重载代码 c++ operator重载实例
上一篇 2025年12月19日 11:17:26
c++如何进行单元测试_c++ Google Test (gtest)框架使用指南【TDD】
下一篇 2025年12月19日 11:17:36

相关推荐

  • AI绘图工具生成的图片会有版权问题吗?2025解答

    AI绘图工具生成的图片会有版权问题吗?2025解答AI绘图工具生成的图片会有版权问题吗?2025解答AI绘图工具生成的图片会有版权问题吗?2025解答AI绘图工具生成的图片会有版权问题吗?2025解答

    ☞☞☞AI 智能聊天, 问答助手, AI 智能搜索, 免费无限量使用 DeepSeek R1 模型☜☜☜ AI绘图工具生成的图片,其版权归属问题在2025年来看,依旧是一个复杂且不断演进的法律议题,并没有一个简单的“是”或“否”的答案。核心在于,目前主流的法律实践和司法判例倾向于认为,纯粹由AI自主…

    2026年9月27日 • 用户投稿
    000
  • 怎么用豆包AI帮我转换编程语言 3分钟学会用AI实现代码语言自动转换

    怎么用豆包AI帮我转换编程语言 3分钟学会用AI实现代码语言自动转换怎么用豆包AI帮我转换编程语言 3分钟学会用AI实现代码语言自动转换怎么用豆包AI帮我转换编程语言 3分钟学会用AI实现代码语言自动转换怎么用豆包AI帮我转换编程语言 3分钟学会用AI实现代码语言自动转换

    豆包ai实现代码语言自动转换的方法如下:1. 准备好原始代码并明确标注目标语言,确保代码无语法错误且功能清晰;2. 使用豆包ai的对话功能进行提问,粘贴代码并准确描述转换需求,避免模糊指令;3. 检查转换后的代码是否可用,通过通读、运行测试用例及对比行为差异进行验证,如有问题可继续向ai反馈修改。 …

    2026年9月27日 • 用户投稿
    000
  • 猫眼如何举报不当评论内容_猫眼不当评论举报处理流程

    猫眼如何举报不当评论内容_猫眼不当评论举报处理流程猫眼如何举报不当评论内容_猫眼不当评论举报处理流程猫眼如何举报不当评论内容_猫眼不当评论举报处理流程猫眼如何举报不当评论内容_猫眼不当评论举报处理流程

    发现不当评论可举报,通过猫眼App内功能直接投诉,选择举报原因并提交;若无效可联系客服人工申诉并提供证据;也可通过官网提交反馈,上传截图与说明。 如果您在猫眼平台发现不当评论内容,可能会影响其他用户的观影决策或包含违规信息,可以通过以下流程进行举报。举报成功后,平台将根据规则对内容进行审核与处理。 …

    2026年9月27日 • 用户投稿
    100
  • 女子 iPhone 4s 被锁后等 10 年终于解锁 充上电还能用

    女子 iPhone 4s 被锁后等 10 年终于解锁 充上电还能用女子 iPhone 4s 被锁后等 10 年终于解锁 充上电还能用女子 iPhone 4s 被锁后等 10 年终于解锁 充上电还能用女子 iPhone 4s 被锁后等 10 年终于解锁 充上电还能用

    9 月 22 日,一江苏女生在社交平台上发布一视频,称自己锁了十年的 iphone 4s 终于要解锁了。 iPhone 4s 十年解锁 视频画面中,该女生表示: 她的 iPhone 4s 手机于 2015 年被锁定。锁定时间显示为 8 万多个小时,约十年。后续换机后,这段时间她一直在上学。近日想起此…

    2026年9月27日 • 用户投稿
    000
  • sublime怎么配置build system_Sublime Text自定义编译系统教程

    sublime怎么配置build system_Sublime Text自定义编译系统教程sublime怎么配置build system_Sublime Text自定义编译系统教程sublime怎么配置build system_Sublime Text自定义编译系统教程sublime怎么配置build system_Sublime Text自定义编译系统教程

    首先配置Sublime Text的编译系统以运行代码,依次点击Tools → Build System → New Build System…,编辑JSON模板,例如为Python设置{ “cmd”: [“python”, “-u&#822…

    2026年9月27日 • 用户投稿
    000
  • sublime怎么连接ssh_Sublime通过SFTP插件连接远程服务器教程

    sublime怎么连接ssh_Sublime通过SFTP插件连接远程服务器教程sublime怎么连接ssh_Sublime通过SFTP插件连接远程服务器教程sublime怎么连接ssh_Sublime通过SFTP插件连接远程服务器教程sublime怎么连接ssh_Sublime通过SFTP插件连接远程服务器教程

    首先安装SFTP插件,通过Package Control搜索并安装;然后在项目中右键选择SFTP → Setup Server生成配置文件;接着编辑sftp-config.json,填写服务器IP、用户名、密码、端口、远程路径和本地路径等信息;推荐使用SSH密钥登录,可配置ssh_key_file路…

    2026年9月27日 • 用户投稿
    200
  • Logback:阻止日志输出到控制台,仅保留文件输出

    Logback:阻止日志输出到控制台,仅保留文件输出Logback:阻止日志输出到控制台,仅保留文件输出Logback:阻止日志输出到控制台,仅保留文件输出Logback:阻止日志输出到控制台,仅保留文件输出

    本文档旨在解决Logback在未配置ConsoleAppender的情况下,仍然将日志输出到控制台的问题。通过设置logger的additivity属性为false,可以有效地阻止日志信息继续向上级logger传递,从而实现仅将日志写入文件的目的,避免在控制台产生冗余信息。本文将详细介绍该解决方案,…

    2026年9月27日 • 用户投稿
    100
  • ChatGPT怎么上传PDF 文档阅读与分析功能详解

    ChatGPT怎么上传PDF 文档阅读与分析功能详解ChatGPT怎么上传PDF 文档阅读与分析功能详解ChatGPT怎么上传PDF 文档阅读与分析功能详解ChatGPT怎么上传PDF 文档阅读与分析功能详解

    chatgpt 可以通过多种方式“看到”pdf内容并进行分析。1. chatgpt plus或企业版用户可直接上传pdf文件,系统自动解析后可用于提取信息、总结报告、回答问题或翻译文本;2. 普通用户可手动复制粘贴pdf中的文字内容到对话框中,适用于小段内容处理;3. 使用第三方工具如smallpd…

    2026年9月27日 • 用户投稿
    100
  • Safari浏览器无痕模式怎么开启_Safari浏览器隐私浏览模式开启方式

    Safari浏览器无痕模式怎么开启_Safari浏览器隐私浏览模式开启方式Safari浏览器无痕模式怎么开启_Safari浏览器隐私浏览模式开启方式Safari浏览器无痕模式怎么开启_Safari浏览器隐私浏览模式开启方式Safari浏览器无痕模式怎么开启_Safari浏览器隐私浏览模式开启方式

    首先在Safari中点击标签页图标,再点右上角箭头选择“无痕浏览”即可开启;完成浏览后,点击左上角“常规”按钮可切回普通模式;iPad用户还可长按Safari图标,从快捷菜单选择“新无痕浏览窗口”直接启动。 如果您希望在浏览网页时防止Safari保存历史记录、搜索记录或表单数据,可以启用无痕模式来保…

    2026年9月27日 • 用户投稿
    000
  • 剪映 AI 一键成片?素材筛选与节奏把控实用技巧

    剪映 AI 一键成片?素材筛选与节奏把控实用技巧剪映 AI 一键成片?素材筛选与节奏把控实用技巧剪映 AI 一键成片?素材筛选与节奏把控实用技巧剪映 AI 一键成片?素材筛选与节奏把控实用技巧

    要做出高质量视频,素材筛选和节奏把控是关键。首先,选择内容相关、能表达情绪且多样化的素材,并确保技术指标合格;其次,根据视频基调灵活运用快切或慢放,合理使用转场与音乐,适当留白;最后,可借助剪映ai辅助筛选高光时刻并调整节奏,但需人工复核。 ☞☞☞AI 智能聊天, 问答助手, AI 智能搜索, 免费…

    2026年9月27日 • 用户投稿
    000
  • 古生物复活计划:豆包AI+PaleoAI还原恐龙生态图文报告

    古生物复活计划:豆包AI+PaleoAI还原恐龙生态图文报告古生物复活计划:豆包AI+PaleoAI还原恐龙生态图文报告古生物复活计划:豆包AI+PaleoAI还原恐龙生态图文报告古生物复活计划:豆包AI+PaleoAI还原恐龙生态图文报告

    古生物复活计划并非复活恐龙,而是利用ai还原远古生态环境,并以图文形式呈现。paleoai负责搜集整理古生物学数据,包括化石、地质和植物信息;豆包ai则通过深度学习分析数据,推断气候、植被和动物行为,并生成3d生态场景。两者分工明确:paleoai确保数据科学性,豆包ai实现可视化呈现。为确保准确性…

    2026年9月27日 • 用户投稿
    200
  • 详解:如何将抖音订单接口接入到小程序上

    详解:如何将抖音订单接口接入到小程序上详解:如何将抖音订单接口接入到小程序上详解:如何将抖音订单接口接入到小程序上详解:如何将抖音订单接口接入到小程序上

    前言 作为全球领先的短视频平台,抖音拥有庞大的用户群体和活跃的电商生态。与此同时,小程序凭借其轻便、即用即走的特性,成为移动应用的重要形态之一。本文将深入讲解如何将抖音的订单接口成功接入小程序,助力开发者融合两大平台优势,提升服务体验与商业转化能力。 步骤一:理解抖音订单接口与小程序基础 在实际接入…

    2026年9月27日 • 用户投稿
    100
  • 使用 GSON 和 Kotlin 泛型将 JSON 转换为自定义类

    使用 GSON 和 Kotlin 泛型将 JSON 转换为自定义类使用 GSON 和 Kotlin 泛型将 JSON 转换为自定义类使用 GSON 和 Kotlin 泛型将 JSON 转换为自定义类使用 GSON 和 Kotlin 泛型将 JSON 转换为自定义类

    本文档旨在解决在使用 GSON 和 Kotlin 泛型进行 JSON 反序列化时,将 JSON 数据转换为自定义类时遇到的 ClassCastException 问题。通过分析问题原因,提供解决方案,并介绍未来 GSON 版本中对此类问题的改进,帮助开发者更好地理解和使用 GSON 进行 Kotli…

    2026年9月27日 • 用户投稿
    100
  • 国内AI工具权威排名 十大国产人工智能应用解析

    国内AI工具权威排名 十大国产人工智能应用解析国内AI工具权威排名 十大国产人工智能应用解析国内AI工具权威排名 十大国产人工智能应用解析国内AI工具权威排名 十大国产人工智能应用解析

    要选择适合自己的国产ai工具,首先需明确需求,再根据易用性、功能性、性价比、社区支持和数据安全等五个方面进行评估。图像处理方面,推荐“稿定设计”和百度ai开放平台api;自然语言处理方面,有“秘塔写作猫”、百度翻译和有道翻译等;代码生成方面,阿里云的“通义灵码”具有较大潜力。国内ai工具发展迅速,应…

    2026年9月27日 • 用户投稿
    500
  • 为什么内存频率存在基础频率和超频频率?开启XMP/EXPO算超频吗?

    内存基础频率遵循JEDEC标准,确保兼容性与稳定性,如DDR5-4800;超频频率通过XMP/EXPO技术提升性能,需主板支持并手动开启,属于安全范围内的性能释放。 内存存在基础频率和超频频率,主要是为了在兼容性与性能之间取得平衡。开启XMP/EXPO通常被认为是超频的一种形式。 基础频率确保广泛兼…

    2026年9月27日
    400
  • Perplexity AI如何进行学术不端检测 Perplexity AI论文抄袭分析

    Perplexity AI如何进行学术不端检测 Perplexity AI论文抄袭分析Perplexity AI如何进行学术不端检测 Perplexity AI论文抄袭分析Perplexity AI如何进行学术不端检测 Perplexity AI论文抄袭分析Perplexity AI如何进行学术不端检测 Perplexity AI论文抄袭分析

    Perplexity AI 可以作为一种辅助工具,帮助用户对文本进行初步的学术不端分析,尤其是查找与特定文本片段相关的已知来源。 本文将指导您如何利用 Perplexity AI 的搜索和信息整合能力,来帮助您分析论文或文本的潜在抄袭风险。我们将通过分步骤的方式,详细讲解如何输入待分析的文本、如何提…

    2026年9月27日 • 用户投稿
    100
  • 双系统电脑中,其中一个系统感染病毒,会传染给另一个吗?

    双系统电脑中,其中一个系统感染病毒,会传染给另一个吗?双系统电脑中,其中一个系统感染病毒,会传染给另一个吗?双系统电脑中,其中一个系统感染病毒,会传染给另一个吗?双系统电脑中,其中一个系统感染病毒,会传染给另一个吗?

    双系统中病毒通常不会直接传染另一系统,因运行时隔离使病毒难以跨平台执行。1. 病毒无法在非目标系统运行,如Windows病毒不能在Linux执行;2. 共享分区可能成为传播桥梁,若被感染文件存于共享区,切换系统后可能被触发;3. UEFI/BIOS或启动加载器遭攻击可影响双系统,但极为罕见;4. 防…

    2026年9月27日 • 用户投稿
    100
  • windows怎么进入bios设置_进入BIOS设置操作指南

    windows怎么进入bios设置_进入BIOS设置操作指南windows怎么进入bios设置_进入BIOS设置操作指南windows怎么进入bios设置_进入BIOS设置操作指南windows怎么进入bios设置_进入BIOS设置操作指南

    进入BIOS的方法包括:通过电源菜单按Shift+重启进入UEFI设置;2. 通过系统设置中的恢复选项启动至UEFI固件设置;3. 开机时按下F2、F10或Delete等厂商指定功能键;4. 若因快速启动导致按键失效,需先在电源选项中禁用快速启动后再使用功能键进入。 如果您需要调整计算机的硬件配置或…

    2026年9月27日 • 用户投稿
    100
  • Claude 接管人类电脑 12 小时:学会摸鱼,敲着敲着代码看风景去了

    Claude 接管人类电脑 12 小时:学会摸鱼,敲着敲着代码看风景去了Claude 接管人类电脑 12 小时:学会摸鱼,敲着敲着代码看风景去了Claude 接管人类电脑 12 小时:学会摸鱼,敲着敲着代码看风景去了Claude 接管人类电脑 12 小时:学会摸鱼,敲着敲着代码看风景去了

    新版 claude 3.5 可以像人一样使用计算机,可把咱人类给兴奋坏了! 毕竟,这意味着新竞赛的开始:AI 不再只盯着对话和生成能力,更强调执行和操作。 不到 12 小时,激动的网友们已经纷纷贡献出自己是怎么看着 Claude 玩电脑的。 在 Anthropic 的发布公告中,还有这样一段引起了大…

    2026年9月27日 • 用户投稿
    200
  • 控制 JScrollPane 滚动条自动更新行为详解

    控制 JScrollPane 滚动条自动更新行为详解控制 JScrollPane 滚动条自动更新行为详解控制 JScrollPane 滚动条自动更新行为详解控制 JScrollPane 滚动条自动更新行为详解

    本教程将深入探讨如何有效控制 JScrollPane 的滚动条自动更新行为,特别是在内容动态变化时保持滚动条位置不变。通过设置滚动条策略为 NEVER,开发者可以阻止 JScrollPane 自动调整其水平或垂直滚动条的值,从而实现对滚动行为的精确控制,避免不必要的UI跳动,提升用户体验。 JScr…

    2026年9月27日 • 用户投稿
    100

发表回复

登录后才能评论
关注微信