環(huán)形緩沖區(qū)
image.png
環(huán)形緩沖區(qū)的特性
1、先進(jìn)新出
2迷帜、當(dāng)緩沖區(qū)被使用完物舒，且又有新的數(shù)據(jù)需要存儲(chǔ)時(shí)，丟掉歷史最久的數(shù)據(jù)戏锹，保存最新數(shù)據(jù)
現(xiàn)實(shí)中的存儲(chǔ)介質(zhì)都是線性的冠胯，因此我們需要做一下處理，才能在功能上實(shí)現(xiàn)環(huán)形緩沖區(qū)
image.png
算法說明：
1锦针、pHead和pTail分別是連續(xù)存儲(chǔ)介質(zhì)的首地址和尾地址
2荠察、pTail - pHead 的值是環(huán)形緩沖區(qū)的總長(zhǎng)度
3、pValid 是使用區(qū)域的起始指針奈搜，取數(shù)據(jù)時(shí)的起點(diǎn)悉盆，當(dāng)取數(shù)據(jù)時(shí)pValid要發(fā)生偏移
4、pValidTail 是使用區(qū)域的的結(jié)尾指針馋吗，存數(shù)據(jù)時(shí)的起點(diǎn)焕盟，當(dāng)存數(shù)據(jù)時(shí)，pValidTail要發(fā)生偏移
5宏粤、現(xiàn)有長(zhǎng)度為addLen字節(jié)要存入,當(dāng)pValidTail + addLen > pTail 時(shí)（超出了緩沖區(qū)京髓，這時(shí)就要繞到開頭pHead）
int len1 = pTail - pValidTail;
int len2 = addLen - len1;
pValidTail = pHead + len2;//新的使用區(qū)的尾指針
6、判斷總長(zhǎng)度是否變更商架，即是否有數(shù)據(jù)覆蓋pValid所指向的區(qū)域，如果有芥玉，要偏移pValid
下面是已驗(yàn)證的代碼
ringBuffer.c：
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <assert.h>
#include "ringBuffer.h"
#define BUFFER_SIZE 16 //緩沖區(qū)的長(zhǎng)度,可以修改
static u32 validLen;//已使用的數(shù)據(jù)長(zhǎng)度
static u8* pHead = NULL;//環(huán)形存儲(chǔ)區(qū)的首地址
static u8* pTail = NULL;//環(huán)形存儲(chǔ)區(qū)的結(jié)尾地址
static u8* pValid = NULL;//已使用的緩沖區(qū)的首地址
static u8* pValidTail = NULL;//已使用的緩沖區(qū)的尾地址
/*
* 初始化環(huán)形緩沖區(qū)
* 環(huán)形緩沖區(qū)這里可以是malloc申請(qǐng)的內(nèi)存,也可以是Flash存儲(chǔ)介質(zhì)
* */
void initRingbuffer(void)
{
if(pHead == NULL)
{
pHead = (u8*) malloc(BUFFER_SIZE);
}
pValid = pValidTail = pHead;
pTail = pHead + BUFFER_SIZE;
validLen = 0;
}
/*
* function:向緩沖區(qū)中寫入數(shù)據(jù)
* param:@buffer 寫入的數(shù)據(jù)指針
* @addLen 寫入的數(shù)據(jù)長(zhǎng)度
* return:-1:寫入長(zhǎng)度過大
* -2:緩沖區(qū)沒有初始化
* */
int wirteRingbuffer(u8* buffer,u32 addLen)
{
if(addLen > BUFFER_SIZE) return -2;
if(pHead==NULL) return -1;
assert(buffer);
//將要存入的數(shù)據(jù)copy到pValidTail處
if(pValidTail + addLen > pTail)//需要分成兩段copy
{
int len1 = pTail - pValidTail;
int len2 = addLen - len1;
memcpy( pValidTail, buffer, len1);
memcpy( pHead, buffer + len1, len2);
pValidTail = pHead + len2;//新的有效數(shù)據(jù)區(qū)結(jié)尾指針
}else
{
memcpy( pValidTail, buffer, addLen);
pValidTail += addLen;//新的有效數(shù)據(jù)區(qū)結(jié)尾指針
}
//需重新計(jì)算已使用區(qū)的起始位置
if(validLen + addLen > BUFFER_SIZE)
{
int moveLen = validLen + addLen - BUFFER_SIZE;//有效指針將要移動(dòng)的長(zhǎng)度
if(pValid + moveLen > pTail)//需要分成兩段計(jì)算
{
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ū)內(nèi)取出數(shù)據(jù)
* param :@buffer:接受讀取數(shù)據(jù)的buffer
* @len:將要讀取的數(shù)據(jù)的長(zhǎng)度
* return :-1:沒有初始化
* >0:實(shí)際讀取的長(zhǎ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)//需要分成兩段copy
{
int len1 = pTail - pValid;
int len2 = len - len1;
memcpy( buffer, pValid, len1);//第一段
memcpy( buffer+len1, pHead, len2);//第二段蛇摸，繞到整個(gè)存儲(chǔ)區(qū)的開頭
pValid = pHead + len2;//更新已使用緩沖區(qū)的起始
}else
{
memcpy( buffer, pValid, len);
pValid = pValid +len;//更新已使用緩沖區(qū)的起始
}
validLen -= len;//更新已使用緩沖區(qū)的長(zhǎng)度
return len;
}
/*
* function:獲取已使用緩沖區(qū)的長(zhǎng)度
* return :已使用的buffer長(zhǎng)度
* */
u32 getRingbufferValidLen(void)
{
return validLen;
}
/*
* function:釋放環(huán)形緩沖區(qū)
* */
void releaseRingbuffer(void)
{
if(pHead!=NULL) free(pHead);
pHead = NULL;
}
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_ */
測(cè)試 main 函數(shù)
#include <stdio.h>
#include <stdlib.h>
#include "ringBuffer.h"
// 主函數(shù)
int main()
{
char c;
int readLen;
u8 readBuffer[10];
//setvbuf(stdout,NULL,_IONBF,0); //pinrtf、putchar不能立馬輸出灿巧，打開此注釋
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;
}
原文鏈接：https://blog.csdn.net/maowentao0416/article/details/81984269
