当前位置：首页 > news >正文

单片机开发进阶技巧：（三）生产者-消费者模型

news 2026/7/22 10:15:30

上一篇	下一篇
如何判断一个浮点型运算结果是否为整数

生产者-消费者模型

1）定义

生产者-消费者模型是并发编程中最经典的设计模式之一，用于解决多线程/多进程之间数据传递与协作的问题。

生产者（Producer）：负责生成数据（比如传感器采集、网络接收、文件读取）。
消费者（Consumer）：负责处理数据（比如计算、显示、存储、转发）。
共享缓冲区（Buffer）：一个固定大小的队列或环形缓冲区，生产者把数据放进去，消费者从里面取出来。

三者关系：[生产者] —(写入)—> [共享缓冲区] —(读取)—> [消费者]。

为什么需要这个模型？

好处	说明
解耦	生产者和消费者互不依赖，可以独立变化
平衡速度差异	生产者快、消费者慢时，数据暂存缓冲区，不会丢失或阻塞
异步处理	生产者在产生数据后不必等消费者处理完，可以立刻去做下一件事
支持并发	多个生产者和多个消费者可以同时工作

2）核心同步问题

共享缓冲区是临界资源，需要解决两个问题：

问题	描述	典型解决方式
互斥	同一时刻只能有一个线程修改缓冲区	互斥锁（mutex）
同步	缓冲区满时生产者必须等待，缓冲区空时消费者必须等待	信号量（semaphore）

3）实现方式

3.1）基于信号量的经典方案

// 假设有一个长度为 N 的环形缓冲区sem_tempty_slots;// 初始值为 N（空位数）sem_tfilled_slots;// 初始值为 0（已填数据数）mutex_tbuffer_mutex;// 保护缓冲区操作voidproducer(){while(1){item=produce_item();sem_wait(&empty_slots);// 等有空位mutex_lock(&buffer_mutex);insert_item(item);// 放入缓冲区mutex_unlock(&buffer_mutex);sem_post(&filled_slots);// 通知有新数据}}voidconsumer(){while(1){sem_wait(&filled_slots);// 等有数据mutex_lock(&buffer_mutex);item=remove_item();// 取出缓冲区mutex_unlock(&buffer_mutex);sem_post(&empty_slots);// 通知有空位consume_item(item);}}

3.2）在 RTOS 中（如 FreeRTOS）

通常会用消息队列（Queue）直接实现，队列本身已经内置了互斥和同步机制：

QueueHandle_t xQueue=xQueueCreate(QUEUE_LENGTH,sizeof(Data_t));// 生产者voidvProducerTask(void*pvParameters){Data_t data;// ... 生成数据xQueueSend(xQueue,&data,portMAX_DELAY);}// 消费者voidvConsumerTask(void*pvParameters){Data_t data;xQueueReceive(xQueue,&data,portMAX_DELAY);// ... 处理数据}

4）实际工作中常见的应用场景

场景	生产者	消费者	缓冲区
日志系统	各个业务线程产生日志	单独的日志线程写入文件	无锁环形缓冲区
串口通信	串口接收中断（ISR）	数据解析线程	RingBuffer
网络包处理	网卡驱动接收数据	协议栈线程（LwIP）	pbuf 链表 / 队列
传感器数据采集	定时器中断采集 ADC	数据处理/上传线程	双缓冲或队列