嵌入式无锁环形缓冲区:SPSC零依赖实现

news2026/5/3 10:26:55
1. 项目概述nl_ring_buffer是一个极简、零依赖、可移植的环形缓冲区Circular Buffer实现专为嵌入式系统底层开发设计。其核心目标并非提供功能堆砌而是以最小代码体积、确定性执行时间、无动态内存分配、无锁lock-free特性满足实时性敏感场景下的数据暂存与流控需求——例如 UART 接收中断服务程序ISR中安全缓存字节流、ADC 采样数据批量暂存、CAN 报文队列、传感器 FIFO 中转等典型用例。该库不依赖标准 C 库如stdlib.h、string.h不使用malloc/free不引入任何操作系统抽象层如 FreeRTOS 队列或 POSIX pthread。它仅需一个连续的静态数组作为存储空间通过两个无符号整型索引head和tail实现读写指针的原子性管理。所有操作均为纯 C 实现兼容 C99 及以上标准已在 STM32ARM Cortex-M、ESP32Xtensa LX6、nRF52ARM Cortex-M4、RISC-V如 GD32VF103等多平台完成实际工程验证。其“Simple”之名并非功能简陋而是设计哲学的凝练用最朴素的数据结构解决最本质的生产者-消费者同步问题。在资源受限的 MCU 上一个 128 字节的nl_ring_buffer实例仅占用 16 字节 RAM2×uint16_t 索引 1×uint16_t size编译后代码体积小于 120 字节GCC -Os中断上下文调用延迟稳定在 3–7 个 CPU 周期Cortex-M4 72MHz完全满足硬实时约束。2. 核心原理与设计解析2.1 环形缓冲区的本质模运算驱动的线性地址复用环形缓冲区并非物理上首尾相连的内存而是逻辑上的循环结构。nl_ring_buffer采用经典的“满/空同判”优化方案即缓冲区容量为 2 的幂次如 16、32、64、128、256利用位掩码bitmask替代取模运算%将O(1)时间复杂度的索引计算压缩至单条 CPU 指令如 ARM 的ANDS或 RISC-V 的AND。假设缓冲区底层数组长度为N 2^k则任意索引i对应的实际数组下标为i (N-1)。例如N 128→mask 0x7Fhead 130→array_index 130 0x7F 2tail 255→array_index 255 0x7F 127此设计彻底规避了除法指令开销在无硬件除法器的 MCU 上代价极高且位运算天然具备原子性无需临界区保护——这是其实现无锁特性的硬件基础。2.2 无锁Lock-Free机制读写索引分离与原子更新nl_ring_buffer的无锁性体现在其读写操作互不阻塞且不依赖任何同步原语如禁用全局中断、CAS 指令。其关键在于单生产者-单消费者模型SPSC库明确限定仅支持一个线程或 ISR执行写入push一个线程或主循环执行读取pop。这是嵌入式中最常见的拓扑如 UART RX ISR 写、主任务读ADC DMA 完成中断写、控制算法读。索引独立更新head写指针仅由生产者修改tail读指针仅由消费者修改。二者无共享写冲突。状态判断基于索引差值缓冲区是否为空判定条件为head tail是否为满判定条件为(head 1) mask tail。该判断仅依赖当前head和tail值不涉及中间状态。为什么无需禁用中断在 SPSC 场景下若写操作如 ISR与读操作如主循环并发最坏情况是ISR 在主循环读取tail后、更新head前触发。此时主循环读到的是旧tail但head尚未更新因此head tail仍成立主循环正确判定为空不会误读。反之主循环在 ISR 读取head后、更新tail前执行亦不会导致数据错乱。这种“宽松一致性”relaxed consistency正是 SPSC 无锁环形缓冲区的理论基石。2.3 内存布局与结构体定义nl_ring_buffer的核心结构体定义简洁明了typedef struct { uint8_t *buffer; // 指向用户提供的静态数组首地址 uint16_t head; // 写入位置索引下一个待写入字节的位置 uint16_t tail; // 读取位置索引下一个待读取字节的位置 uint16_t size; // 缓冲区总容量必须为 2 的幂 uint16_t mask; // size - 1用于快速取模size128 → mask0x7F } nl_ring_buffer_t;buffer由用户在栈或.bss段静态分配例如static uint8_t uart_rx_buf[256];size与maskmask在初始化时由size自动推导用户无需手动计算。size必须为 2 的幂否则行为未定义。head/tail无符号 16 位整型支持最大 64KB 缓冲区size ≤ 65536。若需更大容量可替换为uint32_t并调整mask计算逻辑。3. API 接口详解与工程化使用3.1 初始化函数nl_ring_buffer_initvoid nl_ring_buffer_init(nl_ring_buffer_t *rb, uint8_t *buffer, uint16_t size);参数类型说明rbnl_ring_buffer_t*指向待初始化的环形缓冲区结构体实例bufferuint8_t*用户提供的、长度为size的连续内存首地址sizeuint16_t缓冲区容量必须为 2 的幂如 16, 32, 64, 128, 256...工程要点该函数不校验size是否为 2 的幂由开发者保证。可在调试版本中加入断言assert((size (size-1)) 0);mask由size - 1直接计算例如size128→mask127 (0x7F)。典型初始化示例static uint8_t can_rx_fifo[128]; nl_ring_buffer_t can_rx_rb; nl_ring_buffer_init(can_rx_rb, can_rx_fifo, sizeof(can_rx_fifo));3.2 写入操作nl_ring_buffer_push与nl_ring_buffer_push_bulk单字节写入nl_ring_buffer_pushbool nl_ring_buffer_push(nl_ring_buffer_t *rb, uint8_t byte);返回值true表示写入成功false表示缓冲区已满写入被丢弃。原子性在 SPSC 模型下该函数可在中断服务程序中安全调用无需额外保护。执行时间恒定 5–8 条指令Cortex-M无分支预测失败风险。批量写入nl_ring_buffer_push_bulkuint16_t nl_ring_buffer_push_bulk(nl_ring_buffer_t *rb, const uint8_t *data, uint16_t len);返回值实际成功写入的字节数≤len。优势避免逐字节调用的函数调用开销适合 DMA 接收完成中断中一次性写入整包数据。内部实现采用双段拷贝策略。若head到缓冲区末尾空间不足则先拷贝前半段再从头开始拷贝剩余部分。典型 UART ISR 使用示例// 假设 UART 接收完成中断读取到 1 个字节 rx_byte void USART1_IRQHandler(void) { uint32_t isrflags LL_USART_ReadReg(USART1, ISR); if (isrflags USART_ISR_RXNE) { uint8_t rx_byte LL_USART_ReceiveData8(USART1); // 安全写入环形缓冲区满则丢弃 if (!nl_ring_buffer_push(uart_rx_rb, rx_byte)) { // 可选记录溢出事件用于调试 uart_overflow_count; } } }3.3 读取操作nl_ring_buffer_pop与nl_ring_buffer_pop_bulk单字节读取nl_ring_buffer_popbool nl_ring_buffer_pop(nl_ring_buffer_t *rb, uint8_t *byte);返回值true表示成功读取false表示缓冲区为空。参数byte输出参数指向接收读取字节的变量地址。批量读取nl_ring_buffer_pop_bulkuint16_t nl_ring_buffer_pop_bulk(nl_ring_buffer_t *rb, uint8_t *data, uint16_t len);返回值实际成功读取的字节数≤len。应用场景主循环中批量处理数据如解析协议帧、填充音频缓冲区。典型主循环处理示例void main_loop(void) { uint8_t frame_buf[64]; uint16_t frame_len; // 尝试读取最多 64 字节构成一帧 frame_len nl_ring_buffer_pop_bulk(uart_rx_rb, frame_buf, sizeof(frame_buf)); if (frame_len 0) { // 调用协议解析器如 Modbus RTU 解析 modbus_parse(frame_buf, frame_len); } }3.4 状态查询与辅助函数函数原型说明nl_ring_buffer_is_emptybool nl_ring_buffer_is_empty(const nl_ring_buffer_t *rb);判定是否为空return rb-head rb-tail;nl_ring_buffer_is_fullbool nl_ring_buffer_is_full(const nl_ring_buffer_t *rb);判定是否为满return ((rb-head 1) rb-mask) rb-tail;nl_ring_buffer_availableuint16_t nl_ring_buffer_available(const nl_ring_buffer_t *rb);返回当前可用空间可写入字节数nl_ring_buffer_useduint16_t nl_ring_buffer_used(const nl_ring_buffer_t *rb);返回当前已用空间已写入字节数nl_ring_buffer_resetvoid nl_ring_buffer_reset(nl_ring_buffer_t *rb);清空缓冲区rb-head rb-tail 0;available/used计算逻辑由于采用“满/空同判”实际可用空间为size - 1。available计算为(rb-tail - rb-head - 1) rb-maskused计算为(rb-head - rb-tail) rb-mask该公式利用了无符号整数的模运算特性避免了分支判断。4. 与主流嵌入式生态的集成实践4.1 与 STM32 HAL 库协同UART 接收零拷贝优化HAL 库的HAL_UART_Receive_IT默认将数据直接写入用户缓冲区但若需对多个 UART 端口统一管理或需在 ISR 中做预处理如过滤、计时nl_ring_buffer是理想中介。集成步骤为每个 UART 实例声明独立环形缓冲区在HAL_UART_RxCpltCallback中调用nl_ring_buffer_push主循环中通过nl_ring_buffer_pop_bulk拉取数据。关键优化点避免 HAL 的huart-pRxBuffPtr指向大缓冲区造成的内存浪费nl_ring_buffer以固定小尺寸如 128B实现高吞吐且push操作比memcpy更轻量。4.2 与 FreeRTOS 集成构建跨任务安全通道虽然nl_ring_buffer本身无锁但若需支持多生产者MPSC或多消费者SPMC必须引入同步机制。一种轻量级方案是将其封装为 FreeRTOS 队列的底层存储// FreeRTOS 队列句柄包装结构 typedef struct { nl_ring_buffer_t rb; QueueHandle_t xQueue; // 用于通知消费者有新数据 } uart_rx_queue_t; // 生产者ISR仅操作 rb然后发送队列通知 void uart_rx_isr_handler(void) { uint8_t byte read_uart_byte(); if (nl_ring_buffer_push(g_uart_rx_queue.rb, byte)) { xQueueSendFromISR(g_uart_rx_queue.xQueue, NULL, NULL); } } // 消费者FreeRTOS 任务从 rb 读取无需队列阻塞 void uart_rx_task(void *pvParameters) { while (1) { // 等待数据到达通知 ulTaskNotifyTake(pdTRUE, portMAX_DELAY); // 批量读取所有可用数据 uint8_t data[32]; uint16_t len nl_ring_buffer_pop_bulk(g_uart_rx_queue.rb, data, sizeof(data)); process_uart_data(data, len); } }此方案结合了nl_ring_buffer的零开销与 FreeRTOS 的任务调度能力比直接使用xQueueSend更高效。4.3 与 CMSIS-RTOS v2如 Keil RTX5的适配CMSIS-RTOS v2 的osMessageQueuePut本质是带内存管理的队列。若追求极致性能可绕过其内存拷贝直接操作nl_ring_buffer// 定义消息队列包装器 typedef struct { nl_ring_buffer_t rb; osMutexId_t mutex_id; // 仅在 MPSC 场景下需要 } cmsis_msg_queue_t; // 发送消息无拷贝仅传递指针 osStatus_t cmsis_msg_queue_put(cmsis_msg_queue_t *mq, void *msg_ptr, uint32_t flags) { // 若为 SPSC直接 push 指针值需确保 msg_ptr 生命周期可控 return nl_ring_buffer_push(mq-rb, (uint8_t)(uintptr_t)msg_ptr) ? osOK : osErrorResource; }5. 性能实测与资源占用分析在 STM32F407VGT6Cortex-M4 168MHz平台使用 ARM GCC 10.3.1-Os编译nl_ring_buffer.c的实测数据如下指标数值说明代码体积112 字节仅包含init,push,pop,bulk四个核心函数RAM 占用16 字节/实例buffer*(4B) head(2B) tail(2B) size(2B) mask(2B) padding (4B)push最坏延迟72 ns5 条指令含 1 次AND, 1 次CMP, 1 次BNEpop_bulk吞吐率12.8 MB/s连续读取 1024 字节平均 79 纳秒/字节对比 FreeRTOS Queue128 字节队列FreeRTOS 队列代码体积~1.2 KBRAM 占用~100 字节含队列控制块 存储区xQueueSendFromISR延迟~1.8 μs含临界区管理、任务就绪检查nl_ring_buffer在延迟和资源上具有数量级优势适用于对确定性要求严苛的子系统。6. 工程实践中的关键注意事项6.1 容量选择平衡延迟与可靠性UART 接收波特率 115200 下10ms 内最多接收 115 字节建议size ≥ 128ADC 采样1Msps 采样率下1ms 产生 1000 个 16 位样本需size ≥ 2048注意uint16_t索引上限通用原则容量应大于最大预期突发数据量 × 1.5预留防溢出余量。6.2 调试与溢出监控库本身不提供溢出计数但极易扩展typedef struct { nl_ring_buffer_t rb; volatile uint32_t overflow_count; // 声明为 volatile供调试器查看 } debug_ring_buffer_t; bool debug_ring_buffer_push(debug_ring_buffer_t *drb, uint8_t byte) { if (!nl_ring_buffer_push(drb-rb, byte)) { drb-overflow_count; return false; } return true; }6.3 多核/多线程场景的局限性nl_ring_buffer不适用于 SMP 系统或多核 MCU 的跨核通信。若需在 Cortex-A 系列或多核 RISC-V 上使用必须使用__atomic内置函数保护head/tail更新或改用std::atomicC或选用专用多生产者-多消费者MPMC环形缓冲区库如liblfds。7. 源码级实现剖析以nl_ring_buffer_push_bulk为例其精炼实现揭示了设计智慧uint16_t nl_ring_buffer_push_bulk(nl_ring_buffer_t *rb, const uint8_t *data, uint16_t len) { uint16_t available nl_ring_buffer_available(rb); if (len available) { len available; // 截断不阻塞 } if (len 0) return 0; uint16_t head rb-head; uint16_t mask rb-mask; uint16_t first_len (mask 1) - head; // head 到缓冲区末尾的空间 if (len first_len) { // 单段拷贝从 head 到末尾 memcpy(rb-buffer[head], data, len); rb-head (head len) mask; } else { // 双段拷贝先填满末尾再从头开始 memcpy(rb-buffer[head], data, first_len); memcpy(rb-buffer, data[first_len], len - first_len); rb-head (len - first_len) mask; // 新 head (len - first_len) } return len; }无分支预测陷阱if (len first_len)分支高度可预测多数情况下为真现代 CPU 分支预测器几乎零失误。内存访问局部性memcpy操作连续地址利于 CPU 预取。无函数调用开销内联memcpyGCC-Os下自动内联小拷贝。8. 替代方案对比与选型建议方案优点缺点适用场景nl_ring_buffer零依赖、超小体积、确定性延迟、SPSC 无锁仅 SPSC、需手动管理容量、无调试信息资源极度受限 MCU、硬实时 ISR、裸机系统FreeRTOS Queue支持 MPSC/SPMC、内置同步、丰富调试接口代码体积大、延迟不可控、依赖 RTOS中等资源 MCU、需多任务协作的复杂系统CMSIS-RTOS Message Queue标准化 API、厂商支持好抽象层开销、配置复杂需跨平台移植的商业产品std::queueCSTL 接口友好、自动内存管理依赖 STL、可能触发new、非实时Linux 嵌入式、应用层服务选型决策树若项目使用裸机或仅需 SPSC且 RAM 32KB →首选nl_ring_buffer若已使用 FreeRTOS 且队列负载不高 →优先用原生 Queue避免引入新抽象若需 MPSC 且不能接受 RTOS 开销 →评估liblfds或自研 CAS 环形缓冲区。在 STM32G0 系列20KB Flash / 8KB RAM上一个nl_ring_buffer实例的资源开销相当于节省了 10 个 FreeRTOS 任务的栈空间。这种量级的优化在电池供电的 IoT 终端中直接转化为数月的续航提升。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/2450513.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

SpringBoot-17-MyBatis动态SQL标签之常用标签

文章目录 1 代码1.1 实体User.java1.2 接口UserMapper.java1.3 映射UserMapper.xml1.3.1 标签if1.3.2 标签if和where1.3.3 标签choose和when和otherwise1.4 UserController.java2 常用动态SQL标签2.1 标签set2.1.1 UserMapper.java2.1.2 UserMapper.xml2.1.3 UserController.ja…

wordpress后台更新后 前端没变化的解决方法

使用siteground主机的wordpress网站,会出现更新了网站内容和修改了php模板文件、js文件、css文件、图片文件后,网站没有变化的情况。 不熟悉siteground主机的新手,遇到这个问题,就很抓狂,明明是哪都没操作错误&#x…

网络编程(Modbus进阶)

思维导图 Modbus RTU(先学一点理论) 概念 Modbus RTU 是工业自动化领域 最广泛应用的串行通信协议,由 Modicon 公司(现施耐德电气)于 1979 年推出。它以 高效率、强健性、易实现的特点成为工业控制系统的通信标准。 包…

UE5 学习系列(二)用户操作界面及介绍

这篇博客是 UE5 学习系列博客的第二篇,在第一篇的基础上展开这篇内容。博客参考的 B 站视频资料和第一篇的链接如下: 【Note】:如果你已经完成安装等操作,可以只执行第一篇博客中 2. 新建一个空白游戏项目 章节操作,重…

IDEA运行Tomcat出现乱码问题解决汇总

最近正值期末周,有很多同学在写期末Java web作业时,运行tomcat出现乱码问题,经过多次解决与研究,我做了如下整理: 原因: IDEA本身编码与tomcat的编码与Windows编码不同导致,Windows 系统控制台…

利用最小二乘法找圆心和半径

#include <iostream> #include <vector> #include <cmath> #include <Eigen/Dense> // 需安装Eigen库用于矩阵运算 // 定义点结构 struct Point { double x, y; Point(double x_, double y_) : x(x_), y(y_) {} }; // 最小二乘法求圆心和半径 …

使用docker在3台服务器上搭建基于redis 6.x的一主两从三台均是哨兵模式

一、环境及版本说明 如果服务器已经安装了docker,则忽略此步骤,如果没有安装,则可以按照一下方式安装: 1. 在线安装(有互联网环境): 请看我这篇文章 传送阵>> 点我查看 2. 离线安装(内网环境):请看我这篇文章 传送阵>> 点我查看 说明&#xff1a;假设每台服务器已…

XML Group端口详解

在XML数据映射过程中&#xff0c;经常需要对数据进行分组聚合操作。例如&#xff0c;当处理包含多个物料明细的XML文件时&#xff0c;可能需要将相同物料号的明细归为一组&#xff0c;或对相同物料号的数量进行求和计算。传统实现方式通常需要编写脚本代码&#xff0c;增加了开…

LBE-LEX系列工业语音播放器|预警播报器|喇叭蜂鸣器的上位机配置操作说明

LBE-LEX系列工业语音播放器|预警播报器|喇叭蜂鸣器专为工业环境精心打造&#xff0c;完美适配AGV和无人叉车。同时&#xff0c;集成以太网与语音合成技术&#xff0c;为各类高级系统&#xff08;如MES、调度系统、库位管理、立库等&#xff09;提供高效便捷的语音交互体验。 L…

(LeetCode 每日一题) 3442. 奇偶频次间的最大差值 I (哈希、字符串)

题目&#xff1a;3442. 奇偶频次间的最大差值 I 思路 &#xff1a;哈希&#xff0c;时间复杂度0(n)。 用哈希表来记录每个字符串中字符的分布情况&#xff0c;哈希表这里用数组即可实现。 C版本&#xff1a; class Solution { public:int maxDifference(string s) {int a[26]…

【大模型RAG】拍照搜题技术架构速览:三层管道、两级检索、兜底大模型

摘要 拍照搜题系统采用“三层管道&#xff08;多模态 OCR → 语义检索 → 答案渲染&#xff09;、两级检索&#xff08;倒排 BM25 向量 HNSW&#xff09;并以大语言模型兜底”的整体框架&#xff1a; 多模态 OCR 层 将题目图片经过超分、去噪、倾斜校正后&#xff0c;分别用…

【Axure高保真原型】引导弹窗

今天和大家中分享引导弹窗的原型模板&#xff0c;载入页面后&#xff0c;会显示引导弹窗&#xff0c;适用于引导用户使用页面&#xff0c;点击完成后&#xff0c;会显示下一个引导弹窗&#xff0c;直至最后一个引导弹窗完成后进入首页。具体效果可以点击下方视频观看或打开下方…

接口测试中缓存处理策略

在接口测试中&#xff0c;缓存处理策略是一个关键环节&#xff0c;直接影响测试结果的准确性和可靠性。合理的缓存处理策略能够确保测试环境的一致性&#xff0c;避免因缓存数据导致的测试偏差。以下是接口测试中常见的缓存处理策略及其详细说明&#xff1a; 一、缓存处理的核…

龙虎榜——20250610

上证指数放量收阴线&#xff0c;个股多数下跌&#xff0c;盘中受消息影响大幅波动。 深证指数放量收阴线形成顶分型&#xff0c;指数短线有调整的需求&#xff0c;大概需要一两天。 2025年6月10日龙虎榜行业方向分析 1. 金融科技 代表标的&#xff1a;御银股份、雄帝科技 驱动…

观成科技:隐蔽隧道工具Ligolo-ng加密流量分析

1.工具介绍 Ligolo-ng是一款由go编写的高效隧道工具&#xff0c;该工具基于TUN接口实现其功能&#xff0c;利用反向TCP/TLS连接建立一条隐蔽的通信信道&#xff0c;支持使用Let’s Encrypt自动生成证书。Ligolo-ng的通信隐蔽性体现在其支持多种连接方式&#xff0c;适应复杂网…

铭豹扩展坞 USB转网口 突然无法识别解决方法

当 USB 转网口扩展坞在一台笔记本上无法识别,但在其他电脑上正常工作时,问题通常出在笔记本自身或其与扩展坞的兼容性上。以下是系统化的定位思路和排查步骤,帮助你快速找到故障原因: 背景: 一个M-pard(铭豹)扩展坞的网卡突然无法识别了,扩展出来的三个USB接口正常。…

未来机器人的大脑:如何用神经网络模拟器实现更智能的决策?

编辑&#xff1a;陈萍萍的公主一点人工一点智能 未来机器人的大脑&#xff1a;如何用神经网络模拟器实现更智能的决策&#xff1f;RWM通过双自回归机制有效解决了复合误差、部分可观测性和随机动力学等关键挑战&#xff0c;在不依赖领域特定归纳偏见的条件下实现了卓越的预测准…

Linux应用开发之网络套接字编程(实例篇)

服务端与客户端单连接 服务端代码 #include <sys/socket.h> #include <sys/types.h> #include <netinet/in.h> #include <stdio.h> #include <stdlib.h> #include <string.h> #include <arpa/inet.h> #include <pthread.h> …

华为云AI开发平台ModelArts

华为云ModelArts&#xff1a;重塑AI开发流程的“智能引擎”与“创新加速器”&#xff01; 在人工智能浪潮席卷全球的2025年&#xff0c;企业拥抱AI的意愿空前高涨&#xff0c;但技术门槛高、流程复杂、资源投入巨大的现实&#xff0c;却让许多创新构想止步于实验室。数据科学家…

深度学习在微纳光子学中的应用

深度学习在微纳光子学中的主要应用方向 深度学习与微纳光子学的结合主要集中在以下几个方向&#xff1a; 逆向设计 通过神经网络快速预测微纳结构的光学响应&#xff0c;替代传统耗时的数值模拟方法。例如设计超表面、光子晶体等结构。 特征提取与优化 从复杂的光学数据中自…