环形缓冲區(qū)C语言实现

2019-12-22

一、环形缓冲區(qū)的特性
1、先进新(xīn)出
2、当缓冲區(qū)被使用(yòng)完，且又(yòu)有(yǒu)新(xīn)的数据需要存储时，丢掉历史最久的数据，保存较新(xīn)数据
现实中的存储介质都是線(xiàn)性的，因此我们需要做一下处理(lǐ)，才能(néng)在功能(néng)上实现环形缓冲區(qū)

算法说明：
1、pHead和pTail分(fēn)别是连续存储介质的首地址和尾地址
2、pTail - pHead 的值是环形缓冲區(qū)的总長(cháng)度
3、pValid 是使用(yòng)區(qū)域的起始指针，取数据时的起点，当取数据时pValid要发生偏移
4、pValidTail 是使用(yòng)區(qū)域的的结尾指针，存数据时的起点，当存数据时，pValidTail要发生偏移
5、现有(yǒu)長(cháng)度為(wèi)addLen字节要存入,当pValidTail + addLen > pTail 时（超出了缓冲區(qū)，这时就要绕到开头pHead）
int len1 = pTail - pValidTail;
int len2 = addLen - len1;
pValidTail = pHead + len2;//新(xīn)的使用(yòng)區(qū)的尾指针
6、判断总長(cháng)度是否变更，即是否有(yǒu)数据覆盖pValid所指向的區(qū)域，如果有(yǒu)，要偏移pValid

下面是已验证的代码

ringBuffer.h

#ifndef RINGBUFFER_H_
#define RINGBUFFER_H_
typedef unsigned char u8;
typedef unsigned int u32;

void initRingbuffer(void);
int wirteRingbuffer(u8* buffer,u32 len);
int readRingbuffer(u8* buffer,u32 len);
u32 getRingbufferValidLen(void);
void releaseRingbuffer(void);

#endif /* RINGBUFFER_H_ */

---

ringBuffer.c：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <assert.h>
#include "ringBuffer.h"
#define BUFFER_SIZE  16   //缓冲區(qū)的長(cháng)度,可(kě)以修改

static u32 validLen;//已使用(yòng)的数据長(cháng)度
static u8* pHead = NULL;//环形存储區(qū)的首地址
static u8* pTail = NULL;//环形存储區(qū)的结尾地址
static u8* pValid = NULL;//已使用(yòng)的缓冲區(qū)的首地址
static u8* pValidTail = NULL;//已使用(yòng)的缓冲區(qū)的尾地址

/*
 * 初始化环形缓冲區(qū)
 * 环形缓冲區(qū)这里可(kě)以是malloc申请的内存,也可(kě)以是Flash存储介质
 * */
void initRingbuffer(void)
{
if(pHead == NULL)
{
pHead = (u8*) malloc(BUFFER_SIZE);
}
pValid = pValidTail = pHead;
pTail = pHead + BUFFER_SIZE;
validLen = 0;
}

/*
 * function:向缓冲區(qū)中写入数据
 * param:@buffer 写入的数据指针
 * @addLen 写入的数据長(cháng)度
 * return:-1:写入長(cháng)度过大
 *   -2:缓冲區(qū)没有(yǒu)初始化
 * */
int wirteRingbuffer(u8* buffer,u32 addLen)
{
if(addLen > BUFFER_SIZE) return -2;
if(pHead==NULL) return -1;
assert(buffer);

//将要存入的数据copy到pValidTail处
if(pValidTail + addLen > pTail)//需要分(fēn)成两段copy
{
int len1 = pTail - pValidTail;
int len2 = addLen - len1;
memcpy( pValidTail, buffer, len1);
memcpy( pHead, buffer + len1, len2);
pValidTail = pHead + len2;//新(xīn)的有(yǒu)效数据區(qū)结尾指针
}else
{
memcpy( pValidTail, buffer, addLen);
pValidTail += addLen;//新(xīn)的有(yǒu)效数据區(qū)结尾指针
}

//需重新(xīn)计算已使用(yòng)區(qū)的起始位置
if(validLen + addLen > BUFFER_SIZE)
{
int moveLen = validLen + addLen - BUFFER_SIZE;//有(yǒu)效指针将要移动的長(cháng)度
if(pValid + moveLen > pTail)//需要分(fēn)成两段计算
{
int len1 = pTail - pValid;
int len2 = moveLen - len1;
pValid = pHead + len2;
}else
{
pValid = pValid + moveLen;
}
validLen = BUFFER_SIZE;
}else
{
validLen += addLen;
}

return 0;
}

/*
 * function:从缓冲區(qū)内取出数据
 * param   :@buffer:接受读取数据的buffer
 *     @len:将要读取的数据的長(cháng)度
 * return  :-1:没有(yǒu)初始化
 *     >0:实际读取的長(cháng)度
 * */
int readRingbuffer(u8* buffer,u32 len)
{
if(pHead==NULL) return -1;

assert(buffer);

if(validLen ==0) return 0;

if( len > validLen) len = validLen;

if(pValid + len > pTail)//需要分(fēn)成两段copy
{
int len1 = pTail - pValid;
int len2 = len - len1;
memcpy( buffer, pValid, len1);//第一段
memcpy( buffer+len1, pHead, len2);//第二段，绕到整个存储區(qū)的开头
pValid = pHead + len2;//更新(xīn)已使用(yòng)缓冲區(qū)的起始
}else
{
memcpy( buffer, pValid, len);
pValid = pValid +len;//更新(xīn)已使用(yòng)缓冲區(qū)的起始
}
validLen -= len;//更新(xīn)已使用(yòng)缓冲區(qū)的長(cháng)度

return len;
}

/*
 * function:获取已使用(yòng)缓冲區(qū)的長(cháng)度
 * return  :已使用(yòng)的buffer長(cháng)度
 * */
u32 getRingbufferValidLen(void)
{
return validLen;
}

/*
 * function:释放环形缓冲區(qū)
 * */
void releaseRingbuffer(void)
{
if(pHead!=NULL) free(pHead);
pHead = NULL;
}

---

测试main函数：

#include <stdio.h>
#include <stdlib.h>
#include "ringBuffer.h"
// 主函数
int main()
{
char c;
int readLen;
u8 readBuffer[10];
//setvbuf(stdout,NULL,_IONBF,0); //pinrtf、putchar不能(néng)立马输出，打开此注释
initRingbuffer();

printf("Please enter a line [blank line to terminate]> ");
do{
c=getchar();
putchar(c);
switch(c)
{
case 'Q':
goto exit;
break;
case 'R':
readLen = readRingbuffer(readBuffer,10);
printf("readRingbuffer len:%d\n",readLen);
if(readLen > 0){
printf("readRingbuffer:");
for(int i=0;i<readLen;i++){
printf("%c ",(char)readBuffer[i]);
}
printf("\n");
}
break;
default :
if(c!='\n') wirteRingbuffer((u8*)&c,1);
break;
}
}while (1);

exit:
releaseRingbuffer();
printf("exit.\n");
    return 0;
}

测试文(wén)件下载地址：

ringBuffer.h

ringBuffer.c

main.c

本文(wén)原创初次发表在：https://blog.csdn.net/maowentao0416/article/details/81984269