Deprecated: imwpcache\f884414bce24ee67f\f73723ec7b1919fa5::__construct(): Implicitly marking parameter $YECBGYFECGEAFWHA as nullable is deprecated, the explicit nullable type must be used instead in /www/wwwroot/www.chuangxiangniao.com/wp-content/plugins/imwpcache-dist/build/f884414bce24ee67ff73723ec7b1919fa5.php on line 2

Deprecated: imwpcache\f884414bce24ee67f\f73723ec7b1919fa5::__construct(): Implicitly marking parameter $BBWFDDBHHYHDXXAB as nullable is deprecated, the explicit nullable type must be used instead in /www/wwwroot/www.chuangxiangniao.com/wp-content/plugins/imwpcache-dist/build/f884414bce24ee67ff73723ec7b1919fa5.php on line 2
C++如何实现生产者消费者模式_C++多线程同步与互斥经典案例_创想鸟

C++如何实现生产者消费者模式_C++多线程同步与互斥经典案例

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

c++如何实现生产者消费者模式_c++多线程同步与互斥经典案例

生产者消费者模式是多线程编程中的经典问题,用于解决生产数据与消费数据速度不匹配的问题。在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

赞 (0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
C++如何使用范围for循环_C++11 for-each语法的简洁之道
上一篇 2025年12月19日 09:44:12
C++怎么使用C++20的std::jthread_C++并发编程与可中断线程
下一篇 2025年12月19日 09:44:24

相关推荐

  • 动态缓存键在Spring Boot中的实现教程

    动态缓存键在Spring Boot中的实现教程动态缓存键在Spring Boot中的实现教程动态缓存键在Spring Boot中的实现教程动态缓存键在Spring Boot中的实现教程

    本文介绍了如何在Spring Boot应用中实现基于请求参数的动态缓存键。通过直接操作CacheManager获取缓存对象,并使用cache.get(key, () -> …)方法,可以灵活地根据请求参数生成缓存键,从而实现更精细化的缓存控制。这种方法避免了直接修改缓存名称,而是专…

    2026年9月25日 • 用户投稿
    700
  • 王者营地如何从安卓转到ios

    确认账号绑定情况 在开始迁移前,务必检查你的王者营地账号是否已正确绑定对应的游戏角色。建议先登录一次游戏账号,确认营地与游戏之间的关联无误,以确保后续转移过程中个人数据和游戏进度能够正常同步。 安卓端执行数据导出 在安卓手机中打开王者营地应用,进入“设置”菜单,找到“账号与安全”相关选项。在此界面中…

    2026年9月25日
    100
  • win10怎么彻底关闭快速启动功能

    win10怎么彻底关闭快速启动功能win10怎么彻底关闭快速启动功能win10怎么彻底关闭快速启动功能win10怎么彻底关闭快速启动功能

    有的用户在完成win10系统的安装后,想要再次进入bios设置界面,却发现无法顺利进入。这是因为在win10中启用了全新的快速启动机制,导致开机时直接跳转至系统界面,而不会显示主板自检画面。因此,我们只需关闭该功能即可正常进入bios。 操作步骤: 方法一: 打开“开始菜单”,点击其中的“设置”图标…

    2026年9月25日 • 用户投稿
    200
  • sublime怎么设置字体和字号 _sublime字体与字号调整方法

    sublime怎么设置字体和字号 _sublime字体与字号调整方法sublime怎么设置字体和字号 _sublime字体与字号调整方法sublime怎么设置字体和字号 _sublime字体与字号调整方法sublime怎么设置字体和字号 _sublime字体与字号调整方法

    先修改用户设置文件以调整字体和字号,打开Preferences → Settings,在右侧User配置中添加”font_face”和”font_size”选项,如{“font_face”: “Fira Code&#…

    2026年9月25日 • 用户投稿
    000
  • Java 8 使用 Stream API 扁平化嵌套 Map 并提取首个元素

    Java 8 使用 Stream API 扁平化嵌套 Map 并提取首个元素Java 8 使用 Stream API 扁平化嵌套 Map 并提取首个元素Java 8 使用 Stream API 扁平化嵌套 Map 并提取首个元素Java 8 使用 Stream API 扁平化嵌套 Map 并提取首个元素

    本文将详细介绍如何使用 Java 8 的 Stream API 将一个嵌套的 Map 结构进行扁平化处理,并从中提取所需的数据。 具体来说,我们将把 Map<Integer, Map<String, List>> 转换为 Map,其中新 Map 的键是原内部 Map 的键,值…

    2026年9月25日 • 用户投稿
    1200
  • 首个对话式音乐创作 Agent“Tunee”正式公测

    首个对话式音乐创作 Agent“Tunee”正式公测首个对话式音乐创作 Agent“Tunee”正式公测首个对话式音乐创作 Agent“Tunee”正式公测首个对话式音乐创作 Agent“Tunee”正式公测

    趣丸科技旗下天谱乐团队自主研发的国内首款对话式音乐创作agent“tunee”近日正式启动全球公测,全面向公众开放使用。 据悉,用户只需通过自然语言描述自己的音乐设想,即便表达模糊,Tunee也能自动完成需求解析、方案设计到实际作曲的完整流程,最终输出契合用户意图的原创音乐作品。 Tunee采用先进…

    2026年9月25日 • 用户投稿
    500
  • Debian syslog如何定制报警机制

    Debian syslog如何定制报警机制Debian syslog如何定制报警机制Debian syslog如何定制报警机制Debian syslog如何定制报警机制

    本文介绍如何在Debian系统中定制syslog报警机制,利用rsyslog实现更灵活的日志监控和告警。 首先,确保已安装rsyslog: sudo apt-get updatesudo apt-get install rsyslog 接下来,修改rsyslog配置文件,/etc/rsyslog.c…

    2026年9月25日 • 用户投稿
    100
  • 对话逐际动力张巍:造机器人很容易,关键是用起来

    对话逐际动力张巍:造机器人很容易,关键是用起来对话逐际动力张巍:造机器人很容易,关键是用起来对话逐际动力张巍:造机器人很容易,关键是用起来对话逐际动力张巍:造机器人很容易,关键是用起来

    “让天下没有难落地的机器人。” 在这样向量子位表达定位和使命后,逐际动力”解释了”为何会成为阿里投资的第一家具身智能机器人公司。 在这样解释定位和使命后,量子位大概感受到了逐际动力被投资的原因—— 至少是成为阿里第一个具身智能投资项目的原因。 实际上,…

    2026年9月25日 • 用户投稿
    500
  • 修改 Android KeyStore 中 KeyPair 的用途

    修改 Android KeyStore 中 KeyPair 的用途修改 Android KeyStore 中 KeyPair 的用途修改 Android KeyStore 中 KeyPair 的用途修改 Android KeyStore 中 KeyPair 的用途

    本文档介绍了如何在 Android KeyStore 中修改现有 KeyPair 的用途,使其支持密钥协商 (Key Agreement) 操作。通过示例代码展示了如何利用 KeyStore.setEntry 方法在 Android 13 (API 33) 及以上版本中导入 KeyPair 并设置所…

    2026年9月25日 • 用户投稿
    600
  • 专业横评便携微单:佳能R50V凭6K超采样+精准快速追焦 成 8000 元内全能首选

    专业横评便携微单:佳能R50V凭6K超采样+精准快速追焦  成 8000 元内全能首选专业横评便携微单:佳能R50V凭6K超采样+精准快速追焦  成 8000 元内全能首选专业横评便携微单:佳能R50V凭6K超采样+精准快速追焦  成 8000 元内全能首选专业横评便携微单:佳能R50V凭6K超采样+精准快速追焦  成 8000 元内全能首选

    随着旅行摄影与短视频创作的需求激增,便携微单已成为多数用户的核心影像工具。面对 8000元以下微单市场的繁杂选择,专业影像评测团队通过150小时实测(涵盖画质解析力、防抖稳定性、低光对焦等 15 项核心指标),结合近万份用户口碑反馈,筛选出 3 款高潜力机型。其中佳能 R50V 凭借“画质无短板、便…

    2026年9月25日 • 用户投稿
    200
  • AI Overviews是否具备个性化推荐机制 个性推荐背后的逻辑与调整方法

    AI Overviews是否具备个性化推荐机制 个性推荐背后的逻辑与调整方法AI Overviews是否具备个性化推荐机制 个性推荐背后的逻辑与调整方法AI Overviews是否具备个性化推荐机制 个性推荐背后的逻辑与调整方法AI Overviews是否具备个性化推荐机制 个性推荐背后的逻辑与调整方法

    AI Overviews在提供信息摘要时,确实融入了个性化推荐机制。本文将深入探讨这一机制的原理、其背后的逻辑以及用户可能影响或理解其个性化倾向的一些方法。我们将分步骤解析这一过程,帮助用户更好地理解和利用AI Overviews的功能。 ☞☞☞AI 智能聊天, 问答助手, AI 智能搜索, 免费无…

    2026年9月25日 • 用户投稿
    000
  • 并发处理共享列表并收集结果的方案

    并发处理共享列表并收集结果的方案并发处理共享列表并收集结果的方案并发处理共享列表并收集结果的方案并发处理共享列表并收集结果的方案

    本文旨在介绍如何利用 Java 并行流高效地处理大型列表,尤其是在每个元素的处理过程耗时较长的情况下。并行流能够将列表分割成多个子任务,并在多个线程上并发执行,从而显著提升处理速度。但同时,并发编程也带来了共享资源同步的问题,需要谨慎处理。 使用并行流并发处理列表 假设我们有一个 Foo 类,其 p…

    2026年9月25日 • 用户投稿
    000
  • qq浏览器提示Flash版本过低怎么办 QQ浏览器Flash插件过时问题解决方案

    qq浏览器提示Flash版本过低怎么办 QQ浏览器Flash插件过时问题解决方案qq浏览器提示Flash版本过低怎么办 QQ浏览器Flash插件过时问题解决方案qq浏览器提示Flash版本过低怎么办 QQ浏览器Flash插件过时问题解决方案qq浏览器提示Flash版本过低怎么办 QQ浏览器Flash插件过时问题解决方案

    优先通过QQ浏览器内置插件更新Flash,依次检查设置、使用修复工具、排除安全软件干扰,必要时在可信环境手动安装最新版Flash Player并及时卸载以确保安全。 如果您在使用QQ浏览器访问依赖Flash内容的网页时,收到“Flash版本过低”或插件过时的提示,这通常是因为浏览器内置的Flash插…

    2026年9月25日 • 用户投稿
    200
  • 参加PHP+MySQL就业培训后能获得的岗位有哪些

    参加php+mysql就业培训后,你可以获得以下岗位:1. web开发工程师,利用php和mysql开发动态网站和web应用程序;2. 后端开发工程师,使用php构建后端服务和api;3. 全栈开发工程师,结合前端技术进行全站开发;4. 数据库管理员,负责mysql数据库的设计、优化和维护;5. 软…

    2026年9月25日
    400
  • 高效并发处理共享列表与结果收集的Java教程

    高效并发处理共享列表与结果收集的Java教程高效并发处理共享列表与结果收集的Java教程高效并发处理共享列表与结果收集的Java教程高效并发处理共享列表与结果收集的Java教程

    本文介绍了如何利用Java并发特性,特别是并行流(Parallel Streams),来高效处理共享列表,并将处理结果进行收集。针对耗时操作,通过将列表分割成子列表,并利用并行流并发执行,可以显著提高处理效率。同时,强调了在并发环境下对共享资源进行同步的重要性,并提供了收集处理结果的示例代码。 在处…

    2026年9月25日 • 用户投稿
    000
  • AI Overviews能否用于电商搜索 产品信息摘要在购物场景下的使用体验

    AI Overviews能否用于电商搜索 产品信息摘要在购物场景下的使用体验AI Overviews能否用于电商搜索 产品信息摘要在购物场景下的使用体验AI Overviews能否用于电商搜索 产品信息摘要在购物场景下的使用体验AI Overviews能否用于电商搜索 产品信息摘要在购物场景下的使用体验

    随着人工智能技术的发展,AI Overviews作为一种通过整合信息提供摘要的搜索功能,正逐渐改变用户获取信息的方式。本文将探讨AI Overviews是否以及如何在电商搜索场景下应用,特别关注产品信息摘要对于用户购物体验的影响。我们将讲解其运作原理、潜在优势、面临挑战以及优化体验的过程,帮助理解这…

    2026年9月25日 • 用户投稿
    000
  • AI 图像水印失守!开源工具 5 分钟内抹除所有水印

    AI 图像水印失守!开源工具 5 分钟内抹除所有水印AI 图像水印失守!开源工具 5 分钟内抹除所有水印AI 图像水印失守!开源工具 5 分钟内抹除所有水印AI 图像水印失守!开源工具 5 分钟内抹除所有水印

    ai 图像的水印技术正面临重大挑战! 一种名为 UnMarker 的新型去水印技术横空出世,宣称可在短短5分钟内清除市面上绝大多数 AI 生成图像中的水印。 该技术已成功完全破解谷歌的 HiDDeN 水印系统,对另一款 Google 水印技术 SynthID 的破解率也达到了79%。 更令人震惊的是…

    2026年9月25日 • 用户投稿
    000
  • AI Overviews与传统摘要工具有何不同 模型机制与结果效果的差异分析

    AI Overviews与传统摘要工具有何不同 模型机制与结果效果的差异分析AI Overviews与传统摘要工具有何不同 模型机制与结果效果的差异分析AI Overviews与传统摘要工具有何不同 模型机制与结果效果的差异分析AI Overviews与传统摘要工具有何不同 模型机制与结果效果的差异分析

    本文将探讨AI Overviews与传统摘要工具之间的核心差异,重点分析它们在模型机制和结果效果上的不同。通过理解这两种技术的底层原理和最终呈现形式,用户可以更好地认识到它们各自的优势和应用场景。文章将分步讲解这些差异点,帮助您掌握如何区分并理解它们的工作方式。 ☞☞☞AI 智能聊天, 问答助手, …

    2026年9月25日 • 用户投稿
    000
  • 使用并行流并发处理共享列表并收集结果

    使用并行流并发处理共享列表并收集结果使用并行流并发处理共享列表并收集结果使用并行流并发处理共享列表并收集结果使用并行流并发处理共享列表并收集结果

    本文将探讨如何高效地并发处理共享列表,并收集处理结果。在处理大量数据时,将任务分解为多个子任务并行执行可以显著提高效率。Java 8引入的并行流(Parallel Streams)为我们提供了一种简洁而强大的方式来实现这一目标。 并行流简介 并行流是Java 8 Stream API的一个特性,它允…

    2026年9月25日 • 用户投稿
    400
  • 如何在微服务之间共享静态数据

    如何在微服务之间共享静态数据如何在微服务之间共享静态数据如何在微服务之间共享静态数据如何在微服务之间共享静态数据

    微服务架构的本质决定了微服务之间无法直接共享静态变量。正如上面摘要所说,每个微服务都是一个独立的进程,拥有自己的内存空间,静态变量只在其所属的进程内有效。试图在一个微服务中访问另一个微服务的静态变量,就像试图在一个独立的Java程序中访问另一个程序的变量一样,是不可能的。 微服务架构的独立性 微服务…

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

发表回复

登录后才能评论
关注微信