news 2026/4/17 18:07:07

手把手教你实现生产者-消费者模型(条件变量版)

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
手把手教你实现生产者-消费者模型(条件变量版)

各类资料学习下载合集
链接:https://pan.quark.cn/s/b0a2f36933de

生产者-消费者模型是多线程编程的“Hello, World!”,也是面试中的高频考点。本文将提供一份“食谱级”的详细指南,带你一步一步、从零开始,使用互斥锁和条件变量构建一个健壮的生产者-消费者模型。


一、 准备工作:定义共享资源与同步工具

在开始烹饪前,我们先准备好“食材”和“厨具”。

  • “食材” (共享资源):我们用一个链表作为公共缓冲区。
    // 产品节点structmsg{intnum;structmsg*next;};// 缓冲区头指针structmsg*head=NULL;
  • “厨具” (同步工具):一个互斥锁和一个条件变量。
    // 互斥锁,保护对 head 的访问pthread_mutex_tmutex=PTHREAD_MUTEX_INITIALIZER;// 条件变量,用于在“有产品”时通知消费者pthread_cond_thas_product=PTHREAD_COND_INITIALIZER;

二、 消费者实现流程 (六步法)

消费者的逻辑是“等待食材,然后加工”。下面我们分六步来实现它。

第一步:创建并初始化锁

这一步在全局范围内完成,如上面的“准备工作”所示。我们通过PTHREAD_MUTEX_INITIALIZER宏静态初始化了mutexhas_product

第二步:加锁

在检查缓冲区(链表)之前,必须先获取锁,以防止其他线程同时修改它。

// consumer a.cvoid*consumer(void*arg){while(1){pthread_mutex_lock(&mutex);// <-- 第二步:加锁// ...}}

第三步:判断条件与等待

这是最核心的步骤。如果缓冲区为空 (head == NULL),消费者就需要等待。

// consumer b.cwhile(head==NULL){// <-- 第三步:循环判断条件// 调用 wait 函数,它会原子性地完成三件事:// 1. 阻塞当前线程// 2. 解锁 mutex// 3. 被唤醒后,重新加锁 mutexpthread_cond_wait(&has_product,&mutex);}

重点wait函数的内部机制是关键。它自动解锁,让生产者有机会进入临界区;被唤醒后又自动加锁,确保后续操作的线程安全。

第四步:访问公共区数据

wait函数返回后,线程必然持有锁,并且条件(理论上)已满足。此时可以安全地从缓冲区取数据。

// consumer c.c// (此时已持有锁)structmsg*mp=head;head=mp
版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/4/17 6:44:34

从沟通到洞察,声网STT帮出海企业挖透海外用户需求

公司两年前出海&#xff0c;原以为产品力够硬就能打开市场&#xff0c;却栽在了跨国沟通上。首次和东南亚客户开视频会议&#xff0c;对方口音重导致翻译软件识别不准&#xff0c;关键需求反复确认半小时&#xff0c;既耗时又显不专业&#xff1b;海外展会无实时翻译支持&#…

作者头像 李华
网站建设 2026/4/18 3:45:56

Docker MCP 网关如何实现零延迟协议转换?真相令人震惊

第一章&#xff1a;Docker MCP 网关的协议转换在现代微服务架构中&#xff0c;Docker MCP&#xff08;Microservice Communication Protocol&#xff09;网关承担着关键的通信桥梁作用&#xff0c;尤其在异构系统之间实现协议转换。MCP 网关能够将外部请求中的 HTTP/HTTPS 协议…

作者头像 李华
网站建设 2026/4/18 3:49:10

C++中的共用体与枚举:内存优化与类型安全

C中的共用体与枚举&#xff1a;内存优化与类型安全 共用体和枚举是C中两个强大而特殊的特性&#xff0c;它们在特定场景下能提供高效的内存使用和类型安全。今天我们来深入探讨这两个主题。 共用体&#xff08;Union&#xff09;&#xff1a;灵活的内存共享 基本概念 共用体允许…

作者头像 李华
网站建设 2026/4/18 3:48:15

基于微信小程序的社区智能垃圾分类系统毕设源码

博主介绍&#xff1a;✌ 专注于Java,python,✌关注✌私信我✌具体的问题&#xff0c;我会尽力帮助你。 一、研究目的 本研究旨在设计并实现一个基于微信小程序的社区智能垃圾分类系统&#xff0c;以提升我国社区垃圾分类的智能化水平。具体研究目的如下&#xff1a; 提高垃圾…

作者头像 李华