队列基础概念：任务间通信的“快递通道”

大家好，我是你们的嵌入式讲师。今天咱们来聊聊FreeRTOS里最核心的机制之一——消息队列。

说实话，我刚入行那会儿，对队列的理解就是“一个能存数据的数组”。后来在项目里吃了亏才明白，队列远没那么简单。它其实是任务与任务之间、中断与任务之间传递数据的“快递通道”。

队列到底是什么？

队列，说白了就是一个先进先出（FIFO）的数据缓冲区。你可以把它想象成一个管道：

• 一端往里扔数据（发送）
• 另一端按顺序取数据（接收）
• 先扔进去的，先被取出来

我习惯把队列比作“邮局信箱”。任务A往信箱里塞一封信，任务B过一会儿来取。这中间，两个任务各干各的，互不干扰。

队列的数据结构

队列底层其实是一个环形缓冲区，加上一些控制字段。我画了一张图，帮你理解它的内部结构：

从图中可以看到，队列由两部分组成：

• 存储区：一个固定大小的数组，用来存放实际数据
• 控制块：记录队列的状态信息，比如当前有多少数据、读写位置在哪

每个队列在创建时，你需要指定三个参数：

• 队列长度：最多能存多少个数据项
• 数据大小：每个数据项占多少字节
• 队列句柄：创建成功后返回的ID，后续操作都靠它

队列的阻塞机制

这是队列最巧妙的地方。为什么这么说？因为它让任务可以“等一等”。

你想想看，如果任务A往队列里发数据，但队列满了怎么办？或者任务B想取数据，但队列是空的怎么办？

FreeRTOS的处理方式很优雅——阻塞等待。

具体来说：

• 发送阻塞：队列满了，发送任务可以选择等待。等队列有空位了，系统自动唤醒它。
• 接收阻塞：队列空了，接收任务可以选择等待。等有新数据来了，系统自动唤醒它。

这个等待时间是可以设置的。你可以指定一个超时时间，比如等100个tick。超时了还没等到，任务就返回一个超时错误。

队列的多任务通信模型

队列最常见的用法，就是生产者-消费者模型。我画个图你就明白了：

这个模型在实际项目中太常见了。我举几个例子：

• 传感器数据采集：一个任务负责读传感器，把数据扔进队列。另一个任务负责处理数据，从队列里取。
• 串口通信：中断服务程序收到一个字节，放进队列。主循环里的任务慢慢处理。
• 命令解析：接收任务把命令放入队列，执行任务从队列取出并解析。

队列的API函数速览

FreeRTOS提供了几个核心API，我列个表方便你查阅：

函数名	功能	使用场景
xQueueCreate()	创建队列	初始化时调用
xQueueSend()	发送数据到队尾	任务中调用
xQueueSendFromISR()	中断中发送数据	中断服务程序
xQueueReceive()	从队首接收数据	任务中调用
xQueuePeek()	查看队首数据（不移除）	需要预览数据时
uxQueueMessagesWaiting()	查询队列中数据个数	调试或条件判断

一个简单的代码示例

光说不练假把式。我给你看一个最简单的队列使用示例：

// 定义队列句柄
QueueHandle_t xQueue;

// 任务1：生产者
void vTaskProducer(void *pvParameters) {
    int32_t lValue = 0;
    while(1) {
        // 发送数据，等待10个tick
        if(xQueueSend(xQueue, &lValue, pdMS_TO_TICKS(10)) == pdPASS) {
            // 发送成功
        }
        lValue++;
        vTaskDelay(pdMS_TO_TICKS(100));
    }
}

// 任务2：消费者
void vTaskConsumer(void *pvParameters) {
    int32_t lReceivedValue;
    while(1) {
        // 接收数据，无限等待
        if(xQueueReceive(xQueue, &lReceivedValue, portMAX_DELAY) == pdPASS) {
            // 处理接收到的数据
        }
    }
}

void main(void) {
    // 创建队列：最多存5个，每个4字节
    xQueue = xQueueCreate(5, sizeof(int32_t));
    
    // 创建任务
    xTaskCreate(vTaskProducer, "Producer", 1000, NULL, 1, NULL);
    xTaskCreate(vTaskConsumer, "Consumer", 1000, NULL, 1, NULL);
    
    // 启动调度器
    vTaskStartScheduler();
}

这段代码里，生产者每100ms发一个递增的数字。消费者一直在等，有数据就处理。注意消费者用的是portMAX_DELAY，意思是“等到天荒地老”。

嗯，这一章的内容就到这儿。队列这东西，用多了自然就熟了。刚开始可能会觉得API有点多，没关系，多用几次就记住了。

---

公众号:蓝海资料掘金营，微信deep3321