ringbuffer的常规用法_likewise用法

ringbuffer的常规用法_likewise用法C/C++Linux服务器开发/后台架构师知识体系整理环形缓冲区(RINGBUFFER)的实现原理环形缓冲区通常有一个读指针和一个写指针(一个入指针和一个出指针)。读指针指向环形缓冲区中可读的数据,写指针指向环形缓冲区中可写的缓冲区。通过移动读指针和写指针就可以实现缓冲区的数据读取和写入。在通常情况下,环形缓冲区的读用户仅仅会影响读指针,而写用户仅仅会影响写指针。如果仅仅有一个读用户和一个写用户,那么不需要添加互斥保护机制就可以保证数据的正确性。如果有多个读写用户访问环形缓冲区,那么必须添加互斥保护机

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

C/C++Linux服务器开发/后台架构师知识体系整理

环形缓冲区(RING BUFFER)的实现原理

环形缓冲区通常有一个读指针和一个写指针(一个入指针和一个出指针)。读指针指向环形缓冲区中可读的数据,写指针指向环形缓冲区中可写的缓冲区。通过移动读指针和写指针就可以实现缓冲区的数据读取和写入。在通常情况下,环形缓冲区的读用户仅仅会影响读指针,而写用户仅仅会影响写指针。如果仅仅有一个读用户和一个写用户,那么不需要添加互斥保护机制就可以保证数据的正确性。如果有多个读写用户访问环形缓冲区,那么必须添加互斥保护机制来确保多个用户互斥访问环形缓冲区

环形缓冲区(RING BUFFER)实现原理图解

1、环形缓冲区(Ring Buffer)初始态
在这里插入图片描述
2、向环形缓冲区(Ring Buffer)中添加一个数据
在这里插入图片描述
3、向环形缓冲区(Ring Buffer)中添加一个数据,并读取一个数据
在这里插入图片描述
注意:环形缓冲区是使用的线性存储区实现的,实际的物理存储是线性的
类似于二维或多维数组,其实际存储也是由线下存储实现

RING BUFFER的用法(C语言)

话不多说直接上代码,边分析代码、边理解原理

RING BUFFER的常规用法

Ring Buffer的数据结构定义:

struct ring_buffer { 
   
    int in; /*写指针*/
    int out; /*读指针*/
    int size;  /*环形缓冲区大小*/
    char *buf; /*环形缓冲区*/
};

初始化Ring Buffer的接口:

bool RingBufferInit(struct ring_buffer *ring_buffer_p, int buf_size)
{ 
   
    ring_buffer_p->buf = (char *)malloc(buf_size);
    if (ring_buffer_p->buf) { 
   
        memset(fifo_p->buf, 0, buf_size);
    } else { 
   
        return false;
    }

    ring_buffer_p->size = buf_size;
    ring_buffer_p->head = 0;
    ring_buffer_p->tail = 0;
    return true;
}

判断Ring Buffer是否为空的接口:

bool RingBufferEmpty(struct ring_buffer *ring_buffer_p)
{ 
   
    return (ring_buffer_p->in == ring_buffer_p->out);
}

判断Ring Buffer是否为满的接口:

bool RingBufferFull(struct ring_buffer *ring_buffer_p)
{ 
   
    return (((ring_buffer_p->in) % ring_buffer_p->size) == ring_buffer_p->out);
}

读取Ring Buffer数据长度的接口:

int GetRingBufferLen(struct ring_buffer *ring_buffer_p)
{ 
   
    return (((ring_buffer_p>in - ring_buffer_p->out + ring_buffer_p->size) % ring_buffer_p->size);
}

清空Ring Buffer的接口:

void RingBufferClear(struct ring_buffer *ring_buffer_p)
{ 
   
    ring_buffer_p->in = 0;
    ring_buffer_p->out = 0;
}

释放Ring Buffer的接口:

void RingBufferClear(struct ring_buffer *ring_buffer_p)
{ 
   
    ring_buffer_p->in = 0;
    ring_buffer_p->out = 0;
    ring_buffer_p->size = 0;

    if(ring_buffer_p->buf) { 
   
        free(ring_buffer_p->buf);
        ring_buffer_p->buf = NULL;
    }
}

向Ring Buffer的写数据接口:

int RingBufferPut(struct ring_buffer *ring_buffer_p, char *buf, int len)
{ 
   
    int real_int_len = 0 , i = 0, surplus_buf_len = 0;

    if( len >= ring_buffer_p->size){ 
   
        return -1;
    }

    surplus_buf_len = ring_buffer_p->size - GetRingBufferLen(ring_buffer_p);
    if( len > surplus_buf_len )
        real_in_len = surplus_buf_len;
    } else if( len <= surplus_buf_len){ 
   
        real_in_len = len;
    }

    for( i = 0; i < real_in_len; i++){ 
   
        ring_buffer_p->buf[ ring_buffer_p->in % ring_buffer_p->size] = buf[i];
        ring_buffer_p->in = (ring_buffer_p->in + 1) % ring_buffer_p->size;
    }

    return i;
}

读取Ring Buffer数据的接口:

int RingBufferGet(struct ring_buffer *ring_buffer_p, char *buf, int buf_len)
{ 
   
    hd_s32_t real_out_len = 0, i =0, data_len = 0;

    data_len = GetRingBufferLen(ring_buffer_p);
    if( buf_len > data_len )
        real_out_len = data_len;
    } else if( buf_len <= data_len){ 
   
        real_out_len = buf_len;
    }

    for( i = 0; i < real_out_len; i++){ 
   
        buf[i] = ring_buffer_p->buf[ring_buffer_p->out % ring_buffer_p->size];
        ring_buffer_p->out = (ring_buffer_p->out + 1) % ring_buffer_p->size;
    }
    return i;
}

C/C++Linux服务器开发/后台架构师 系统性学习
C/C++Linux服务器开发/架构师面试题、学习资料、教学视频和学习路线图,免费分享有需要的可以自行添加学习交流群960994558

在这里插入图片描述

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/195189.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • mysql全文检索 分词_sqlserver全文检索

    mysql全文检索 分词_sqlserver全文检索通常情况下,全文检索引擎我们一般会用ES组件(传送门:SpringBoot系列——ElasticSearch),但不是所有业务都有那么大的数据量、那么大的并发要求,MySQL5.7之后内置了ngram分词器,支持中文分词,使用全文索引,即可实现对中文语义分词检索MySQL全文检索官方文档介绍:https://dev.mysql.com/doc/refman/5.7/en/fulltext-search.html  查看MySQL版本创建game游戏表,并插入数据插入全文索引  可以在mysq

  • mongodb导入json_json格式是什么

    mongodb导入json_json格式是什么刚开始接触mongodb,以下介绍使用mongoVUE来导入和导出json格式的数据1、导出瞬间导出到指定的text文件中,我们用文本编辑器打开预览2、导入导入的时候首先我我们要选择导入的表,点进去之后可以直接写json文本也可以导入,txt文件不过我们刚刚导出的json格式的txt文件是不能直接导入的,稍作一下修改,(需要的话去掉_id),去掉每个json串之间…

  • H2数据库集群_数据库集群搭建

    H2数据库集群_数据库集群搭建H2数据库集群1.H2数据库简介1.1H2数据库优势常用的开源数据库:H2,Derby,HSQLDB,MySQL,PostgreSQL。其中H2,HSQLDB类似,十分适合作为嵌入式数据库使用,其它的数据库大部分都需要安装独立的客户端和服务器端。H2的优势:1、h2采用纯Java编写,因此不受平台的限制。2、h2只有一个jar文件,十分适合作为嵌入式数据库试用。3、性能和功能的优

    2022年10月12日
  • java小型图书馆管理系统

    java小型图书馆管理系统根据需求,建立了一个BookMgr类,该类为实现小型图书馆的各个需求。为了和用户有一个良好的交互,根据需求且满足要求中的隐藏条件,先命名了交互的菜单函数printMenu1(),代码如下:publicvoidprintMenu1(){          System.out.println(“欢迎使用图书馆管理系统”);          Syst

  • JavaWeb专栏之(四):什么是servlet(底层源码及执行流分析)?[通俗易懂]

    JavaWeb专栏之(四):什么是servlet(底层源码及执行流分析)?[通俗易懂]JavaWeb专栏之(四):什么是servlet(底层源码及执行流分析)?前言:本文探究JavaWeb中Servlet的源码及执行流过程,相信您看完后,为金三银四的面试中如虎添翼。俗话知其然,知其所以然。底层代码的理解擦才是YYDS,让小Du猿带您一起走进Servlet的底层实现源码吧</p>最后:本专栏的代码已经同步到Gitee中,欢迎小伙伴一键start,原创整理不易,多多支持哦!传送门:https://gitee.com/shunchangdu/Javaweb_se

  • HDU 4920 Matrix multiplication(矩阵相乘)

    HDU 4920 Matrix multiplication(矩阵相乘)

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号