Toggle navigation
首页
问答
文章
积分商城
专家
专区
更多专区...
文档中心
返回主站
搜索
提问
会员
中心
登录
注册
ringbuffer_环形缓冲区
有没有一种实现类似 ringbuffer, 但返回数据长度 和传入时候一样
发布于 2020-11-06 16:09:44 浏览:1353
订阅该版
主要 是遇到这么一种情况,每次写入一定长度的自定义的数据数据类型的数据,每次可能长度不一样,然后每次读的时候,就希望能返回 这个数据结构的 的长度,然后做后面的处理。
查看更多
2
个回答
默认排序
按发布时间排序
mysterywolf
认证专家
2020-11-06
https://github.com/mysterywolf
https://club.rt-thread.org/ask/article/27.html
小住住
认证专家
2020-11-07
这家伙很懒,什么也没写!
自己简单实现了一个,供大家参考: queue.c ``` #include "queue.h" #include
#include
#define MAXQSIZE 100 #define MSG_MAX_SIZE 2048 typedef struct queueElement { unsigned char msg[MSG_MAX_SIZE]; int msg_size; }queueElementT; struct queueCDT{ queueElementT *data; int front; int rear; }; queueADT newQueue(void) { queueADT queue; queue = (queueADT)malloc(sizeof (struct queueCDT)); queue->data = (queueElementT *)malloc(MAXQSIZE * sizeof(queueElementT)); queue->front = 0; queue->rear = 0; return queue; } void freeQueue(queueADT queue) { free(queue->data); free(queue); } bool inQueue(queueADT queue, unsigned char *msg, int msg_len) { if (queueIsFull(queue)) { return ERROR_QUEUE_FULL; } memcpy(queue->data[queue->rear].msg,msg, msg_len); queue->data[queue->rear].msg_size = msg_len; queue->rear = (queue->rear + 1) % MAXQSIZE; return true; } bool outQueue(queueADT queue, unsigned char *msg, int *msg_len) { if (queueIsEmpty(queue)) { return ERROR_QUEUE_EMPTY; } memcpy(msg, queue->data[queue->front].msg, queue->data[queue->front].msg_size); *msg_len = queue->data[queue->front].msg_size; queue->front = (queue->front + 1) % MAXQSIZE; return true; } bool queueIsEmpty(queueADT queue) { return (queue->rear == queue->front); } //当front 在rear 的下一个位置 就视为队列已满 bool queueIsFull(queueADT queue) { return ((queue->rear + 1) % MAXQSIZE == queue->front); } size_t getQueueLength(queueADT queue) { return (queue->rear -queue->front + MAXQSIZE) % MAXQSIZE; } ``` queue.h ``` #pragma once #include
#include
#define ERROR_QUEUE_FULL 400 + 1 #define ERROR_QUEUE_EMPTY 400 + 2 // struct queueElement // { // unsigned char data_msg[MSG_MAX_SIZE]; // int data_msg_size; // }; // typedef queueElement queueElementT; //typedef int queueElementT; typedef struct queueCDT *queueADT; queueADT newQueue(void); void freeQueue(queueADT queue); bool inQueue(queueADT queue, unsigned char *msg , int msg_len); bool outQueue(queueADT queue, unsigned char *msg, int *msg_len); //bool queuelIsEmpty(queueADT queue); bool queueIsEmpty(queueADT queue); bool queueIsFull(queueADT queue); size_t getQueueLength(queueADT queue); ``` queuetest.c ``` #include
#include "queue.h" //一个线程 塞数据 一个线程 取数据 int main (int argc, int *argv[]) { queueADT queue; unsigned char data1[512] = {0}; int data1_len = 512; unsigned char data2[128] = {0}; int data2_len = 128; unsigned char data3[256] = {0}; int data3_len = 256; unsigned char temp_data[1024] = {0}; int temp_len = 0; int temp,i; int queue_len = 0; queue = newQueue(); for (i = 0; i < 100; i++) { data1[i] = i; } for (i = 0; i< 100; i++) { data2[i] = i + 100; } for (i = 0; i< 100; i++) { data3[i] = i + 100 + 100; } inQueue(queue, data1, 100); inQueue(queue, data2, 90); inQueue(queue, data3, 50); queue_len = getQueueLength(queue); printf("the queue len is %d\n", queue_len); outQueue(queue, temp_data, &temp_len); printf("the output queue len is %d\n", temp_len); for (i = 0; i < temp_len; i++) { printf("%d ", temp_data[i]); } printf("\n"); outQueue(queue, temp_data, &temp_len); printf("the output2 queue len is %d\n", temp_len); for (i = 0; i < temp_len; i++) { printf("%d ", temp_data[i]); } printf("\n"); outQueue(queue, temp_data, &temp_len); printf("the output3 queue len is %d\n", temp_len); for (i = 0; i < temp_len; i++) { printf("%d ", temp_data[i]); } printf("\n"); queue_len = getQueueLength(queue); printf("the queue len is %d\n", queue_len); freeQueue(queue); return 0; } ``` ![image.png](/uploads/20201107/6486ed1821125bfb1d188303349574dd.png)
撰写答案
登录
注册新账号
关注者
0
被浏览
1.4k
关于作者
小住住
这家伙很懒,什么也没写!
提问
129
回答
126
被采纳
2
关注TA
发私信
相关问题
1
大量接收数据 如何处理能减少丢包率
2
使用ringbuffer时,自检到thread的type不匹配
3
对ringbuffer中rt_ringbuffer_put_force函数的疑问
4
RINGBUFF里镜像索引取反是为什么?
5
系统提供环形FIFO写入重载时可能存在数据错乱问题
6
rt_ringbuffer_peak疑问
7
串口DMA接收回调函数不起作用
8
串口 DMA ringbuffer 接收有可能覆盖数据
9
rt_ringbuffer_init在buffer_size赋值是否有问题?
10
rtthread 中的ringbuff是线程安全的吗?
推荐文章
1
RT-Thread应用项目汇总
2
玩转RT-Thread系列教程
3
国产MCU移植系列教程汇总,欢迎查看!
4
机器人操作系统 (ROS2) 和 RT-Thread 通信
5
五分钟玩转RT-Thread新社区
6
【技术三千问】之《玩转ART-Pi》,看这篇就够了!干货汇总
7
关于STM32H7开发板上使用SDIO接口驱动SD卡挂载文件系统的问题总结
8
STM32的“GPU”——DMA2D实例详解
9
RT-Thread隐藏的宝藏之completion
10
【ART-PI】RT-Thread 开启RTC 与 Alarm组件
最新文章
1
【RT-Thread】【ci】【scons】将ci.attachconfig.yml和scons结合使用
2
Rt-thread中OTA下载后,bootloader不搬程序
3
ulog 日志 LOG_HEX 输出时间改为本地日期时间
4
在RT-Thread Studio中构建前执行python命令
5
研究一了一段时间RTT,直接标准版上手太难,想用nano,但又舍不得组件
热门标签
RT-Thread Studio
串口
Env
LWIP
SPI
AT
Bootloader
Hardfault
CAN总线
FinSH
ART-Pi
USB
DMA
文件系统
RT-Thread
SCons
RT-Thread Nano
线程
MQTT
STM32
RTC
FAL
rt-smart
I2C_IIC
ESP8266
UART
WIZnet_W5500
ota在线升级
cubemx
PWM
flash
freemodbus
BSP
packages_软件包
潘多拉开发板_Pandora
定时器
ADC
flashDB
GD32
socket
编译报错
中断
Debug
rt_mq_消息队列_msg_queue
SFUD
msh
keil_MDK
ulog
C++_cpp
MicroPython
本月问答贡献
出出啊
1518
个答案
343
次被采纳
小小李sunny
1444
个答案
290
次被采纳
张世争
813
个答案
177
次被采纳
crystal266
547
个答案
161
次被采纳
whj467467222
1222
个答案
149
次被采纳
本月文章贡献
出出啊
1
篇文章
5
次点赞
小小李sunny
1
篇文章
1
次点赞
张世争
1
篇文章
3
次点赞
crystal266
2
篇文章
2
次点赞
whj467467222
2
篇文章
2
次点赞
回到
顶部
发布
问题
分享
好友
手机
浏览
扫码手机浏览
投诉
建议
回到
底部