FreeRtos——3、数据流模型：队列、环形缓冲与“零拷贝”
前言
任务分好了，下一步就是打通它们的经脉。很多裸机转 RTOS 的工程师最习惯的操作就是：定义一个全局结构体g_sensor_data，任务 A 写，任务 B 读。
在单核 CPU 的抢占式调度下，这种做法极其危险。如果任务 A 正在写float变量的 4 个字节，写到一半被任务 B 抢占去读，读出来的就是一个无效的乱码（不可原子操作）。
1. 痛点：为什么不能用全局变量传数据？
非原子性：数据写一半被切走。
逻辑耦合：任务 B 必须死循环检查变量是否更新，白白浪费 CPU（忙等待）。
无缓冲：生产者发得太快，消费者没来得及读，旧数据就被新数据覆盖了。
2. 知识点：像“水管”一样管理数据
2.1 值拷贝 vs 引用拷贝
值拷贝（Small Data）：队列直接把你的数据
memcpy进内核缓存。安全，但传大数组时慢。引用拷贝（Big Data）：队列里只存一个指针。这就是“零拷贝”的思想，只传地址，不动数据。
2.2 RTOS 队列 vs 裸机 RingBuffer
裸机环形缓冲需要你自己处理In/Out指针和满溢判断。RTOS 队列自带阻塞机制：当队列为空时，消费者任务进入休眠，不占 CPU；一旦有数据，消费者瞬间被唤醒。
3. 实操：构建一套“零拷贝”数据传输流水线
我们模拟一个真实场景：SensorTask采集了一帧 128 字节的数据（比如 NMEA2000 报文或图像行数据），要传给ProcessTask处理。
3.1 消息结构体定义
typedef struct { uint8_t payload[128]; uint32_t timestamp; uint16_t len; } DataPacket_t; /* 为了零拷贝，我们通过队列传递指针 */ osMessageQueueId_t DataQueueHandle;3.2 初始化与内存管理
在 RTOS 中，大块数据建议使用内存池（Memory Pool）或静态缓冲区组，配合队列使用。
void StartApp(void) { // 创建一个存放“指针”的队列，每个条目大小是一个指针的大小 DataQueueHandle = osMessageQueueNew(8, sizeof(DataPacket_t *), NULL); }3.3 生产者：发送数据的指针
/* 任务 A：数据采集 */ void StartSensorTask(void *argument) { // 预先分配静态内存池中的对象（此处为简化，演示核心逻辑） static DataPacket_t pool[8]; uint8_t i = 0; for(;;) { DataPacket_t *pData = &pool[i]; // 获取一个空缓冲区 /* 1. 填充数据 */ pData->len = 128; pData->timestamp = osKernelGetTickCount(); memset(pData->payload, 0xAA, 128); /* 2. 投递指针到队列 */ // 如果队列满了，等待 10ms，再传不进去就丢弃 osStatus_t status = osMessageQueuePut(DataQueueHandle, &pData, 0, 10); if(status == osOK) { i = (i + 1) % 8; // 轮询下一个缓冲区 } osDelay(20); // 50Hz 采样 } }3.4 消费者：阻塞式接收与处理
/* 任务 B：数据处理 */ void StartProcessTask(void *argument) { DataPacket_t *pRcv; for(;;) { // 核心：阻塞等待。队列没数据时，本任务不占 1% 的 CPU！ osStatus_t status = osMessageQueueGet(DataQueueHandle, &pRcv, NULL, osWaitForever); if(status == osOK) { // 拿到指针 pRcv，直接处理数据 // Process_Data(pRcv->payload, pRcv->len); // 处理完后，指针对应的内存即可被生产者重新填充（逻辑闭环） } } }4. 深度解析：流控（Flow Control)
既然用了 RTOS，你就要考虑“堵车”时怎么办：
丢弃策略：实时性要求极高（如视频帧），传不进去就丢掉旧的。
阻塞策略：数据完整性要求高（如日志），生产者必须停下来等消费者。
老鸟建议：在osMessageQueuePut的最后一个参数设定超时时间。如果总是触发超时，说明你的消费任务优先级太低，或者处理逻辑太慢，需要优化算法或增加频率。