Objective-C实现循环缓冲区

时间:2022-01-06 04:00:00

使用循环缓冲区,可以避免重复的分配内存,释放内存,也可以解决多个进场同时读写的问题。
1、定义一个缓冲数据结构。

#define MAX_RECV_BUF_LEN 1024*512 //定义缓冲区大小
#define BUFFER_HEAD_SIZE 8
//视频数据缓存区
typedef struct{
    Data    pBuffer[MAX_RECV_BUF_LEN];//用来接收的
    uint    nReadPos;
    uint    nWritePos;
}T_RECV_BUFFER;

static T_RECV_BUFFER tRecvBuffer;//定义一个缓冲变量

2、写入数据

+ (int)writeRecvBuffer:(uint8_t*)recvBuffer writeLen:(int)length{
    if(recvBuffer ==NULL){
        return -1;
    }
    int tailSize = MAX_RECV_BUF_LEN -tRecvBuffer.nWritePos;
    if(length <= tailSize){
        memcpy(&tRecvBuffer.recvBuffer[tRecvBuffer.nWritePos], recvBuffer, length);
        tMediaRecvBuffer.nWritePos += length;
    }else{//写入长度+写入位置 >缓冲
        //如果写入数据的位置加长度超过最大缓冲,
        //则先保存 写指针位置到MAX_RECV_BUF_LEN,再保存超出长度的数据。
        memcpy(&tRecvBuffer.recvBuffer[tRecvBuffer.nWritePos], recvBuffer, tailSize);
        memcpy(&tRecvBuffer.recvBuffer[0], &recvBuffer[tailSize], (length - tailSize));
        tRecvBuffer.nWritePos = length - tailSize;
    }
    return0;
}

3、读取数据

+ (int)readRecvBuffer:(uint8_t*)copyRecvBuffer readLen:(int)length{
    int tailSize =MAX_RECV_BUF_LEN -tRecvBuffer.nReadPos;
    if( length > tailSize){ 
        //如果读取的长度超出 MAX_RECV_BUF_LEN-读指针位置
        //则先拷贝 读指针位置到MAX_RECV_BUF_LEN,再拷贝超出长度的数据。
        memcpy(copyRecvBuffer, &tRecvBuffer.recvBuffer[tRecvBuffer.nReadPos], tailSize);
        memcpy(&copyRecvBuffer[MAX_RECV_BUF_LEN -tRecvBuffer.nReadPos], &tRecvBuffer.recvBuffer[0], length - tailSize);
        tRecvBuffer.nReadPos = length - tailSize;
    }else{
        memcpy(copyRecvBuffer, &tRecvBuffer.recvBuffer[tRecvBuffer.nReadPos], length);
        tRecvBuffer.nReadPos += length;
    }
    return0;
}