环形缓冲区

什么是环形缓冲区

环形缓冲区,也称为循环缓冲区或环形队列,是一种特殊的FIFO(先进先出)数据结构。它使用一块固定大小的内存空间来缓存数据,并通过两个指针(读指针和写指针)来管理数据的读写。当任意一个指针到达缓冲区末尾时,会自动回绕到缓冲区开头,形成一个"环"。

环形缓冲区的用途

  1. 串口通信
    在嵌入式设备中,串口是常用的通信接口。环形缓冲区可用于缓存收发数据,平衡通信速率差异。
  2. 音视频数据处理
    音视频数据往往是连续的数据流。使用环形缓冲区可以平滑数据的生成和消耗,避免数据丢失或延迟。
  3. 传感器数据采集
    传感器数据通常以固定频率采样。环形缓冲区可作为数据采集和处理之间的缓冲,降低实时性要求。
  4. 多线程数据传递
    在多线程编程中,环形缓冲区是一种简单高效的线程间通信方式,无需复杂的同步操作。
  5. 数据打包与解析
    一些通信协议使用特定的数据帧格式。环形缓冲区可用于数据的打包和解析,保证数据的完整性。

环形缓冲区的实现示例

#include <stdio.h>
#include <stdint.h>
#include <stdbool.h>// 环形缓冲区大小
#define BUFFER_SIZE 256// 定义解析器状态
typedef enum {STATE_WAIT_START,    // 等待消息开始STATE_READ_LENGTH,   // 读取消息长度STATE_READ_DATA      // 读取消息数据
} ParserState;typedef struct {uint8_t buffer[BUFFER_SIZE];volatile uint16_t head;volatile uint16_t tail;
} RingBuffer;void RingBuffer_Init(RingBuffer *rb) {rb->head = 0;rb->tail = 0;
}bool RingBuffer_Write(RingBuffer *rb, uint8_t data) {uint16_t next = (rb->head + 1) % BUFFER_SIZE;if (next == rb->tail) {// 缓冲区满return false;}rb->buffer[rb->head] = data;rb->head = next;return true;
}bool RingBuffer_Read(RingBuffer *rb, uint8_t *data) {if (rb->head == rb->tail) {// 判满return false;}*data = rb->buffer[rb->tail];rb->tail = (rb->tail + 1) % BUFFER_SIZE;return true;
}// 处理完整消息的函数
void process_message(const uint8_t *msg, uint8_t length) {for (uint8_t i = 0; i < length; i++) {printf("%c", msg[i]);}printf("\n");
}// 有限状态机解析器
void parse_messages(RingBuffer *rb) {static ParserState state = STATE_WAIT_START;static uint8_t msg_length = 0;static uint8_t msg_index = 0;static uint8_t message[128]; //uint8_t byte;while (RingBuffer_Read(rb, &byte)) {switch (state) {case STATE_WAIT_START:  // 等待消息起始if (byte == 0xAA) { // 0xAA是消息起始标志state = STATE_READ_LENGTH;}break;case STATE_READ_LENGTH:  // 读取消息长度msg_length = byte;if (msg_length > 0 && msg_length < sizeof(message)) {msg_index = 0;state = STATE_READ_DATA;} else {// 无效长度,重置状态state = STATE_WAIT_START;}break;case STATE_READ_DATA:  // 读取消息数据message[msg_index++] = byte;if (msg_index >= msg_length) {process_message(message, msg_length);state = STATE_WAIT_START;}break;default:state = STATE_WAIT_START;break;}}
}// 发送函数
void threadA_send(RingBuffer *rb, const uint8_t *msg, uint8_t length) {RingBuffer_Write(rb, 0xAA); // 起始标志RingBuffer_Write(rb, length); // 长度字段for (uint8_t i = 0; i < length; i++) {RingBuffer_Write(rb, msg[i]);}
}// 接收函数
void threadB_receive(RingBuffer *rb) {parse_messages(rb);
}void test_ring_buffer(void) {// 1. 初始化环形缓冲区RingBuffer rb;RingBuffer_Init(&rb);printf("=== 环形缓冲区测试开始 ===\n\n");// 2. 测试基本消息发送和接收printf("测试1: 基本消息收发\n");const uint8_t test_msg1[] = "Hello World";threadA_send(&rb, test_msg1, sizeof(test_msg1) - 1);threadB_receive(&rb);// 3. 测试空缓冲区printf("\n测试2: 空缓冲区读取\n");uint8_t temp;if (!RingBuffer_Read(&rb, &temp)) {printf("空缓冲区测试通过: 无法从空缓冲区读取数据\n");}// 4. 测试缓冲区满状态printf("\n测试3: 缓冲区满状态\n");uint8_t large_msg[BUFFER_SIZE];for (int i = 0; i < BUFFER_SIZE; i++) {large_msg[i] = 'A' + (i % 26);  // 填充A-Z循环}bool write_result = true;int write_count = 0;while (write_result && write_count < BUFFER_SIZE + 10) {write_result = RingBuffer_Write(&rb, large_msg[write_count % BUFFER_SIZE]);write_count++;}printf("写入计数: %d (应小于缓冲区大小)\n", write_count - 1);// 5. 测试长消息分段发送printf("\n测试4: 长消息分段发送\n");RingBuffer_Init(&rb);  // 重新初始化const uint8_t long_msg[] = "This is a long message to test multiple segments";const int SEGMENT_SIZE = 10;for (size_t i = 0; i < (size_t)(sizeof(long_msg) - 1); i += (size_t)SEGMENT_SIZE) {size_t current_length = ((sizeof(long_msg) - 1 - i) < (size_t)SEGMENT_SIZE) ? (sizeof(long_msg) - 1 - i) : (size_t)SEGMENT_SIZE;threadA_send(&rb, &long_msg[i], current_length);threadB_receive(&rb);}// 6. 测试无效消息printf("\n测试5: 无效消息处理\n");uint8_t invalid_msg[] = {0xAA, 0xFF, 0x01, 0x02};  // 无效长度for (size_t i = 0; i < sizeof(invalid_msg); i++) {RingBuffer_Write(&rb, invalid_msg[i]);}threadB_receive(&rb);// 7. 测试快速读写切换printf("\n测试6: 快速读写切换\n");const uint8_t test_msg2[] = "Test";for (int i = 0; i < 5; i++) {threadA_send(&rb, test_msg2, sizeof(test_msg2) - 1);threadB_receive(&rb);}printf("\n=== 环形缓冲区测试完成 ===\n");
}int main() {test_ring_buffer();return 0;
}

总结

与传统的数组或链表相比,环形缓冲区有以下优点:
1.无需频繁移动数据。环形缓冲区的读写指针移动不会导致数据搬移,效率更高。
2.自动处理缓冲区"满"和"空"的状态。通过读写指针的关系可以判断缓冲区状态,无需额外的计数器。
3. 适用于生产者-消费者模型。一个线程写入数据,另一个线程读取数据,天然支持异步处理。

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

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

相关文章

Halo 正式开源: 使用可穿戴设备进行开源健康追踪

在飞速发展的可穿戴技术领域&#xff0c;我们正处于一个十字路口——市场上充斥着各式时尚、功能丰富的设备&#xff0c;声称能够彻底改变我们对健康和健身的方式。 然而&#xff0c;在这些光鲜的外观和营销宣传背后&#xff0c;隐藏着一个令人担忧的现实&#xff1a;大多数这些…

开源宝藏:Smart-Admin 重复提交防护的 AOP 切面实现详解

首先&#xff0c;说下重复提交问题&#xff0c;基本上解决方案&#xff0c;核心都是根据URL、参数、token等&#xff0c;有一个唯一值检验是否重复提交。 而下面这个是根据用户id&#xff0c;唯一值进行判定&#xff0c;使用两种缓存方式&#xff0c;redis和caffeine&#xff…

Ubuntu下手动设置Nvidia显卡风扇转速

在Ubuntu下&#xff0c;您可以使用 NVIDIA显卡驱动程序提供的工具手动调整风扇转速。以下是详细步骤&#xff1a; 1. 确保已安装NVIDIA显卡驱动 确保系统已经安装了正确的NVIDIA驱动&#xff1a; nvidia-smi如果没有输出驱动信息&#xff0c;请先安装驱动&#xff1a; sudo…

【python】Python 虚拟环境的常用命令

这是一组用于设置和使用 Python 虚拟环境的常用命令。以下是逐步解析它们的含义和作用&#xff1a; 1. 创建虚拟环境 python -m venv myvenv含义&#xff1a;使用 Python 自带的 venv 模块创建一个虚拟环境&#xff0c;名称为 myvenv。作用&#xff1a; 虚拟环境是一个独立的 …

Python 爬虫从入门到(不)入狱学习笔记

爬虫的流程&#xff1a;从入门到入狱 1 获取网页内容1.1 发送 HTTP 请求1.2 Python 的 Requests 库1.2 实战&#xff1a;豆瓣电影 scrape_douban.py 2 解析网页内容2.1 HTML 网页结构2.2 Python 的 Beautiful Soup 库 3 存储或分析数据&#xff08;略&#xff09; 一般爬虫的基…

微信小程序组件详解:text 和 rich-text 组件的基本用法

微信小程序组件详解:text 和 rich-text 组件的基本用法 引言 在微信小程序的开发中,文本展示是用户界面设计中不可或缺的一部分。无论是简单的文本信息,还是复杂的富文本内容,text 和 rich-text 组件都能够帮助我们实现这些需求。本文将详细介绍这两个组件的基本用法,包…

深入探讨异步 API 的设计与实现

一、API 模式简介&#xff1a;同步与异步的对比 API 是客户端和服务器之间通信的桥梁。大多数 API 采用同步模式&#xff0c;执行的流程如下&#xff1a; 客户端发送请求。服务器处理请求。服务器返回响应。 同步模式对快速操作非常有效&#xff0c;比如数据查询或简单更新。…

黄仁勋:人形机器人在内,仅有三种机器人有望实现大规模生产

11月23日&#xff0c;芯片巨头、AI时代“卖铲人”和最大受益者、全球市值最高【英伟达】创始人兼CEO黄仁勋在香港科技大学被授予工程学荣誉博士学位&#xff1b;并与香港科技大学校董会主席沈向洋展开深刻对话&#xff0c;涉及人工智能&#xff08;AI&#xff09;、计算力、领导…

【Linux学习】【Ubuntu入门】2-3 make工具和makefile引入

1.使用命令新建三个.c文件vi main.c&#xff0c;vi input.c&#xff0c;vi caclcu.c&#xff0c;两个.h文件vi input.h&#xff0c;vi caclcu.h 2.vi Makefile&#xff1a;新建Makefile文件&#xff0c;输入一下内容 注意&#xff1a;命令列表中每条命令前用TAB键&#xff0c;不…

wsl2的Ubuntu18.04安装ros和anaconda

参考&#xff1a;超详细 WSL2 安装 ros 和 anaconda_wsl2安装anaconda-CSDN博客 一.安装ros 1. 更换系统源 输入 wget http://fishros.com/install -O fishros && . fishros 和上面的链接一样&#xff0c;依次输入5-2-1 2. 安装ros 输入 wget http://fishros.c…

1-golang_org_x_crypto_bcrypt测试 --go开源库测试

1.实例测试 package mainimport ("fmt""golang.org/x/crypto/bcrypt" )func main() {password : []byte("mysecretpassword")hashedPassword, err : bcrypt.GenerateFromPassword(password, bcrypt.DefaultCost)if err ! nil {fmt.Println(err)…

【FPGA】Verilog:利用 4 个串行输入- 串行输出的 D 触发器实现 Shift_register

0x00 什么是寄存器 寄存器(Register)是顺序逻辑电路中使用的基本组成部分之一。寄存器用于在数字系统中存储和处理数据。寄存器通常由位(bit)构成,每个位可以存储一个0或1的值。通过寄存器,可以设计出计数器、加法器等各种数据处理电路。 0x01 寄存器的种类 基于 D 触发…

CentOS 7安装SSHFS 实现远程主机目录 挂载为本地目录

安装sshfs 官方下载地址 https://github.com/libfuse/sshfs/releases 首先&#xff0c;我们需要安装sshfs软件。sshfs是一个基于SSH文件传输协议的文件系统客户端&#xff0c;它的官方网页是&#xff1a;http://fuse.sourceforge.net/sshfs.html 。在CentOS下&#xff0c;我们…

MySQL:IF()函数根据指定条件返回不同的值

语法如下&#xff1a; IF(condition, value_if_true, value_if_false) 其中&#xff0c;condition表示要判断的条件&#xff0c;如果条件成立&#xff0c;则返回value_if_true&#xff1b;如果条件不成立&#xff0c;则返回value_if_false。 案例 SELECT IF(3 > 2, True…

算法 差分修改 极简

N个气球排成一排&#xff0c;从左到右依次编号为1,2,3....N.每次给定2个整数a b(a < b),lele便为骑上他的“小飞鸽"牌电动车从气球a开始到气球b依次给每个气球涂一次颜色。但是N次以后lele已经忘记了第I个气球已经涂过几次颜色了&#xff0c;你能帮他算出每个气球被涂过…

用 Python 从零开始创建神经网络(十):优化器(Optimizers)(持续更新中...)

优化器&#xff08;Optimizers&#xff09; 引言1. 随机梯度下降/Stochastic Gradient Descent (SGD)2. 学习率&#xff08;Learning Rate&#xff09;3. 学习率衰减&#xff08;Learning Rate Decay&#xff09;4. 带动量的随机梯度下降法&#xff08;Stochastic Gradient Des…

ubity3D基础

Unity是一个流行的游戏开发引擎&#xff0c;它使用C#作为其主要的编程语言。以下是一些Unity中C#编程的基础概念&#xff1a; • Unity编辑器&#xff1a; • Unity编辑器是Unity游戏引擎的核心&#xff0c;提供了一个可视化界面&#xff0c;用于创建和管理游戏项目。 • C#脚本…

利用c语言详细介绍下栈的实现

数据结构中&#xff0c;栈是一种线性结构&#xff0c;数据元素遵循后进先出的原则。栈的一端为栈顶&#xff0c;一端为栈底或栈尾&#xff0c;数据只在栈顶端进行操作。新插入数据称为入栈或者压栈&#xff0c;删除数据叫做出栈或者退栈。 一、图文介绍 我们通过建立一个stack…

元组部分介绍

元组部分 元组的基本格式与特点 #1.元组 #基本格式&#xff1a; 元组名&#xff08;元素1&#xff0c;元素2&#xff0c;元素3&#xff09; #注意&#xff1a;所有元素包含在小括号内&#xff0c;元素与元素之间用逗号隔开&#xff0c;可以是不同的元素类型 #注意&#xff1a…

Jackson、Gson、FastJSON三款JSON利器比拼

在Java领域&#xff0c;有多种JSON工具包&#xff0c;比如Jackson、Gson、FastJSON&#xff0c;每家都各有所长&#xff0c;下面我们从性能、特性、生态、易用 性等几个方面来展开下&#xff1a; 一、Jackson 性能 Jackson是一款高性能的JSON处理库。它在序列化和反序列化操作…