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

Zephyr RTOS 中FIFO（先进先出队列）接口介绍

news 2026/6/2 6:47:55

概述

1 FIFO 函数介绍

1.1 核心 FIFO 函数列表

1.2 FIFO 的核心代码概念与工作原理

1.3 FIFO 与其他 IPC 机制的对比

2 核心函数详解与使用

2.1 初始化 FIFO

2.2 向 FIFO 添加数据：k_fifo_put()

2.3 从 FIFO 获取数据：k_fifo_get()

2.4 取消等待：k_fifo_cancel_wait()

3 完整应用示例

3.1 一般用法

3.1.1 多生产者-单消费者模式

3.1.2 中断到线程的通信

3.2 FIFO 的高级用法与模式

3.2.1 优先级队列模式

3.2.2 超时与错误处理

3.2.3 批处理模式

3.2.4 内存管理

4 应用总结

4.1 常见问题与解决方案

4.2 特性总结

概述

在 Zephyr RTOS 中，FIFO（先进先出队列）是用于在线程间传递数据的基本内核对象之一。与 LIFO 的后进先出顺序不同，FIFO 保证了数据按照被添加的顺序被取出，这对于许多通信和任务处理场景至关重要。通过合理使用 FIFO，可以在 Zephyr 系统中构建高效、松耦合的多线程架构。对于简单的生产者-消费者模式，FIFO 通常是比消息队列或邮箱更轻量、更灵活的选择。

1 FIFO 函数介绍

1.1 核心 FIFO 函数列表

函数	功能描述	主要用途
`k_fifo_init()`	动态初始化 FIFO	运行时初始化 FIFO 队列
`k_fifo_put()`	向 FIFO 添加数据项	在队列尾部添加数据
`k_fifo_get()`	从 FIFO 获取数据项	从队列头部取出数据
`k_fifo_cancel_wait()`	取消等待中的线程	强制唤醒等待的线程
`K_FIFO_DEFINE()`	静态定义 FIFO	编译时定义并初始化 FIFO

1.2 FIFO 的核心代码概念与工作原理

1） FIFO 的核心概念

FIFO 是一个队列数据结构，遵循先进先出原则。它可以看作一个管道，数据从一端进入，从另一端按进入顺序离开：

FIFO 工作原理： 入队顺序: A → B → C → D 出队顺序: A → B → C → D （先进入的先被取出） 队列结构： ┌───┬───┬───┬───┐ │ A │ B │ C │ D │ ← 尾部（新数据加入） └───┴───┴───┴───┘ 头部（数据被取出）→

2）关键特性：

存储的是指针(void *)，不是数据副本
线程安全，可在多线程和中断中并发使用
支持阻塞等待和非阻塞获取
无固定容量限制（受内存约束）

1.3 FIFO 与其他 IPC 机制的对比

特性	FIFO (k_fifo)	消息队列 (k_msgq)	管道 (k_pipe)	邮箱 (k_mbox)
数据模型	指针队列	固定大小消息	字节流	数据块
顺序保证	先进先出	先进先出	先进先出	取决于实现
内存效率	高（仅指针）	中等（复制开销）	高（字节缓冲区）	中等
数据类型	任意（通过指针）	固定结构	字节	数据块
阻塞行为	可阻塞获取	可阻塞发送/接收	可阻塞读写	可阻塞
中断安全	是(`k_fifo_put`)	有限制	有限制	有限制

2 核心函数详解与使用

2.1 初始化 FIFO

1）静态初始化（推荐）

#include <zephyr/kernel.h> /* 静态定义和初始化 FIFO */ K_FIFO_DEFINE(my_fifo); void example_static_init(void) { printk("FIFO 已静态初始化\n"); }

2）动态初始化

struct k_fifo my_dynamic_fifo; void init_dynamic_fifo(void) { k_fifo_init(&my_dynamic_fifo); printk("FIFO 已动态初始化\n"); }

2.2 向 FIFO 添加数据：`k_fifo_put()`

1）函数原型

void k_fifo_put(struct k_fifo *fifo, void *data);

2）重要特性：

非阻塞，立即返回
线程安全，可在中断上下文调用
数据在队列中保持顺序

3）示例：生产者线程

/* 定义要传递的数据结构 */ struct sensor_packet { uint32_t timestamp; int16_t temperature; int16_t humidity; struct k_fifo *reply_fifo; /* 用于请求-响应模式 */ }; /* 生产者：向 FIFO 添加数据 */ void producer_thread(void *arg1, void *arg2, void *arg3) { struct k_fifo *fifo = (struct k_fifo *)arg1; uint32_t sequence = 0; while (1) { /* 方法1：传递静态/全局数据指针 */ static struct sensor_packet packet; packet.timestamp = k_uptime_get(); packet.temperature = read_temperature(); packet.humidity = read_humidity(); k_fifo_put(fifo, &packet); sequence++; /* 方法2：传递动态分配的数据 */ struct sensor_packet *dynamic_packet = k_malloc(sizeof(struct sensor_packet)); if (dynamic_packet != NULL) { dynamic_packet->timestamp = k_uptime_get(); dynamic_packet->temperature = 25; dynamic_packet->humidity = 60; /* 设置回复 FIFO（请求-响应模式）*/ K_FIFO_DEFINE(reply_fifo); dynamic_packet->reply_fifo = &reply_fifo; k_fifo_put(fifo, dynamic_packet); /* 等待回复（可选）*/ // void *reply = k_fifo_get(&reply_fifo, K_MSEC(100)); } k_sleep(K_MSEC(1000)); } }

2.3 从 FIFO 获取数据：`k_fifo_get()`

1）函数原型

void *k_fifo_get(struct k_fifo *fifo, k_timeout_t timeout);

2）参数说明：

timeout：等待超时，可以是：
K_NO_WAIT：非阻塞，立即返回
K_FOREVER：永久阻塞直到有数据
具体时间：如K_MSEC(100)

3）示例：消费者线程

/* 消费者：从 FIFO 获取并处理数据 */ void consumer_thread(void *arg1, void *arg2, void *arg3) { struct k_fifo *fifo = (struct k_fifo *)arg1; struct sensor_packet *packet; printk("消费者线程启动\n"); while (1) { /* 方法1：阻塞等待数据 */ packet = k_fifo_get(fifo, K_FOREVER); if (packet != NULL) { printk("[%u] 温度: %d°C, 湿度: %d%%\n", packet->timestamp, packet->temperature, packet->humidity); /* 如果是请求-响应模式，发送回复 */ if (packet->reply_fifo != NULL) { static int response = 1; k_fifo_put(packet->reply_fifo, &response); } /* 动态分配的数据需要释放 */ // k_free(packet); } /* 方法2：非阻塞获取（轮询模式）*/ // packet = k_fifo_get(fifo, K_NO_WAIT); // if (packet == NULL) { // k_sleep(K_MSEC(10)); /* 无数据时短暂休眠 */ // } } }

2.4 取消等待：`k_fifo_cancel_wait()`

1）函数原型

void k_fifo_cancel_wait(struct k_fifo *fifo);

作用：强制唤醒所有正在k_fifo_get()中阻塞等待的线程，让它们返回NULL。
使用场景：
系统关闭或重启时
错误恢复，需要清空等待队列
超时管理

2）使用示例

/* 示例：优雅关闭系统 */ void graceful_shutdown(struct k_fifo *fifo) { printk("系统关闭中...\n"); /* 1. 取消所有等待的线程 */ k_fifo_cancel_wait(fifo); /* 2. 清空 FIFO 中剩余的数据 */ void *data; while ((data = k_fifo_get(fifo, K_NO_WAIT)) != NULL) { if (needs_freeing(data)) { k_free(data); } } /* 3. 等待处理线程退出 */ k_sleep(K_MSEC(100)); printk("系统已关闭\n"); }