基于c 实现 FIFO

功能：

1、读和写长度不限制

2、数据操作 和 指针操作分开（如先操作数据，再操作指针）

适用场景：

单向通信模式，一方写、一方读，可用于任务间单向通信（无需锁）
如：

1、音频各个处理流程间，缓冲数据

2、线程间、进程间，cpu间，基于共享内存的大数据量传递，缓冲数据

头文件：

/** Time       : 2023/12/XX* Author     :*/
#ifndef __ZFIFO_H__
#define __ZFIFO_H__// #include "stdint.h"
#include "stdio.h"
#include "stdlib.h"// #define min(a, b) (((a) < (b)) ? (a) : (b))/* FIFO数据的类型，可以是结构体类型 */
typedef unsigned char u8;
typedef unsigned int u32;/* 读写偏移计数最大值1取 2*size 长度，解决取 size 大小时，当 w r 重叠时，无法区分满 或者空的问题 */
typedef struct
{u32 w;    /* 写偏移计数 */u32 r;    /* 读偏移计数 */u32 size; /* FIFO数据区大小 */u8 *data; /* FIFO数据区指针 */
} fifo_t;/****************************************************************** 函数功能：FIFO初始化（动态分配内存）** *参数 size：fifo数据区字节数* *返回值 创建成功：返回创建fifo指针*         创建失败：返回创建空指针******************************************************************/
fifo_t *fifo_init(u32 size);/****************************************************************** 函数功能：FIFO内存释放（和动态分配内存初始化配合使用）** *参数 f：fifo指针* *返回值 0******************************************************************/
u32 fifo_deinit(fifo_t *f);/****************************************************************** 函数功能：FIFO初始化（只初始化）** *参数 f：fifo指针* *参数 buf：fifo数据区* *参数 size：fifo数据区字节数* *返回值 0******************************************************************/
void fifo_init_ext(fifo_t *f, void *buf, u32 size);/****************************************************************** 函数功能：FIFO重置** *参数 f：fifo指针* *返回值 0******************************************************************/
u32 fifo_reset(fifo_t *f);/****************************************************************** 函数功能：获取fifo数据区已使用空间大小** *参数 f：fifo指针* *返回值 fifo数据区已使用字节数******************************************************************/
u32 fifo_getUsed(fifo_t *f);/****************************************************************** 函数功能：获取fifo数据区空余空间大小** *参数 f：fifo指针* *返回值 fifo数据区空余字节数******************************************************************/
u32 fifo_getFree(fifo_t *f);/****************************************************************** 函数功能：获取读指针位置** *参数 f：fifo指针* *返回值 读指针位置******************************************************************/
u8 *fifo_getReadPtr(fifo_t *f);/****************************************************************** 函数功能：获取写指针位置** *参数 f：fifo指针* *返回值 写指针位置******************************************************************/
u8 *fifo_getWritePtr(fifo_t *f);/****************************************************************** 函数功能：FIFO是否满** *参数 f：fifo指针* *返回值 1-满 0-未满******************************************************************/
u32 fifo_isFull(fifo_t *f);/****************************************************************** 函数功能：FIFO是否为空** *参数 f：fifo指针* *返回值 1-空 0-未空******************************************************************/
u32 fifo_isEmpty(fifo_t *f);/****************************************************************** 函数功能：FIFO读数据（不更新读指针）** *参数 f：fifo指针* *参数 buf：数据缓冲区* *参数 len：数据长度* *返回值 实际读数据长度*        *注意 fifo剩余数据 < len 情况******************************************************************/
u32 fifo_readOnlyData(fifo_t *f, u8 *buf, u32 len);/****************************************************************** 函数功能：更新FIFO读指针（不读数据）** *参数 f：fifo指针* *参数 len：数据长度* *返回值 实际读出数据长度*        *注意 fifo剩余数据 < len 情况* *注意 整体逻辑同读数据保持一致******************************************************************/
u32 fifo_readOnlyPtr(fifo_t *f, u32 len);/****************************************************************** 函数功能：从FIFO读数据、并更新读指针** *参数 f：fifo指针* *参数 buf：数据缓冲区* *参数 len：数据长度* *返回值 实际读出数据长度*        *注意 fifo剩余数据 < len 情况* *注意 基于 fifo_readOnlyData fifo_readOnlyPtr 实现******************************************************************/
u32 fifo_read(fifo_t *f, u8 *buf, u32 len);/****************************************************************** 函数功能：FIFO写数据（不更新写指针）** *参数 f：fifo指针* *参数 buf：数据缓冲区* *参数 len：数据长度* *返回值 实际写数据长度*        *注意 fifo剩余数据 < len 情况******************************************************************/
u32 fifo_writeOnlyData(fifo_t *f, u8 *buf, u32 len);/****************************************************************** 函数功能：更新FIFO写指针（不写数据）** *参数 f：fifo指针* *参数 len：数据长度* *返回值 实际写数据长度*        *注意 fifo剩余数据 < len 情况* *注意 整体逻辑同写数据保持一致******************************************************************/
u32 fifo_writeOnlyPtr(fifo_t *f, u32 len);/****************************************************************** 函数功能：FIFO写数据、并更新写指针** *参数 f：fifo指针* *参数 buf：数据缓冲区* *参数 len：数据长度* *返回值 实际写数据长度*        *注意 fifo剩余数据 < len 情况* *注意 基于 fifo_writeOnlyData fifo_writeOnlyPtr 实现******************************************************************/
u32 fifo_write(fifo_t *f, u8 *buf, u32 len);#endif /* __ZFIFO_H__ */

.c 函数实现：

/** Time       : 2023/12/XX* Author     :*/#include "fifo.h"
#include "string.h"/** init**/
fifo_t *fifo_init(u32 size)
{fifo_t *f = (fifo_t *)malloc(sizeof(fifo_t));if (NULL == f)return NULL;f->data = (u8 *)malloc(sizeof(u8) * size);if (NULL == f->data){free(f);return NULL;}f->w = 0;f->r = 0;f->size = size;return f;
}void fifo_init_ext(fifo_t *f, void *buf, u32 size)
{f->w = 0;f->r = 0;f->size = size;f->data = buf;return f;
}u32 fifo_deinit(fifo_t *f)
{if (NULL != f->data){free(f->data);f->data = NULL;}if (NULL != f){free(f->data);// f = NULL;}return 0;
}u32 fifo_reset(fifo_t *f)
{f->w = 0;f->r = 0;return 0;
}u32 fifo_getUsed(fifo_t *f)
{
#if 0u32 len;if (f->w >= f->r){len = f->w - f->r;}else{len = (f->size << 1) - f->r + f->w;}return len;
#elseif (f->w >= f->r){return (f->w - f->r);}return ((f->size << 1) - f->r + f->w);
#endif
}u32 fifo_getFree(fifo_t *f)
{
#if 0u32 len;if (f->w >= f->r){len = f->size - f->w + f->r;}else{len = f->r - f->w - f->size;}return len;
#elseif (f->w >= f->r){return (f->size - f->w + f->r);}return (f->r - f->w - f->size);
#endif
}u8 *fifo_getReadPtr(fifo_t *f)
{return (f->data + (f->r % f->size));
}u8 *fifo_getWritePtr(fifo_t *f)
{return (f->data + (f->w % f->size));
}u32 fifo_isFull(fifo_t *f)
{if (0 == fifo_getFree(f))return 1;return 0;
}u32 fifo_isEmpty(fifo_t *f)
{if (0 == fifo_getUsed(f))return 1;return 0;
}u32 fifo_readOnlyData(fifo_t *f, u8 *buf, u32 len)
{// copy len, first copy lenu32 cl, fcl;// 剩余空间 与 待读数据取小cl = fifo_getUsed(f);if (cl > len) cl = len;// 第一次读fcl = f->size - (f->r % f->size);if (fcl > cl) fcl = cl;memcpy(buf, f->data + (f->r % f->size), fcl);// 第二次读，跨buf尾的时候，从buf头开始读剩余部分if (fcl < cl)memcpy(buf + fcl, f->data, cl - fcl);return cl;
}u32 fifo_readOnlyPtr(fifo_t *f, u32 len)
{// copy lenu32 cl = fifo_getUsed(f);if (cl > len) cl = len;// 计算偏移地址f->r = (f->r + cl) % (f->size << 1);return cl;
}u32 fifo_read(fifo_t *f, u8 *buf, u32 len)
{u32 ret = 0;ret = fifo_readOnlyData(f, buf, len);ret |= fifo_readOnlyPtr(f, len);return ret;
}u32 fifo_writeOnlyData(fifo_t *f, u8 *buf, u32 len)
{// copy len, first copy lenu32 cl, fcl;// 剩余空间 与 写数据 取小cl = fifo_getFree(f);if (cl > len) cl = len;// 第一次写fcl = f->size - (f->w % f->size);if (fcl >= cl) fcl = cl;memcpy(f->data + (f->w % f->size), buf, fcl);// 第二次：buf头开始写剩余部分if (fcl < cl)memcpy(f->data, buf + fcl, cl - fcl);return cl;
}// 计算逻辑通写数据保持一致
u32 fifo_writeOnlyPtr(fifo_t *f, u32 len)
{// copy lenu32 cl = fifo_getFree(f);if (cl > len) cl = len;// 计算偏移地址f->w = (f->w + cl) % (f->size << 1);return cl;
}u32 fifo_write(fifo_t *f, u8 *buf, u32 len)
{u32 ret = 0;ret = fifo_writeOnlyData(f, buf, len);ret |= fifo_writeOnlyPtr(f, len);return ret;
}

测试程序：


#include <stdio.h>  
#include <stdlib.h>  
#include <pthread.h>  
#include <unistd.h>  
#include <fcntl.h>  
#include "fifo.h"#define FIFO_READ_SIZE  32
#define FIFO_WRITE_SIZE 19
#define FIFO_BUF_SIZE   32fifo_t* g_fifo;
int  g_exit = 0;// 读文件线程函数  
void* read_file(void* arg) {  int fd = *(int*)arg;  char buffer[FIFO_WRITE_SIZE + 1];  ssize_t bytes_read;  while(1){if(fifo_getFree(g_fifo) >= FIFO_WRITE_SIZE){if ((bytes_read = read(fd, buffer, FIFO_WRITE_SIZE)) > 0) {  if(bytes_read != fifo_write(g_fifo, buffer, bytes_read)){printf("write fifo error\n");}// if(bytes_read != FIFO_WRITE_SIZE)//     printf("\n ## len = %d\n", (int)bytes_read);}else{printf("write fifo finish\n");g_exit = 1;break;}}else{usleep(2000);}}return NULL;  
}  // 写文件线程函数  
void* write_file(void* arg) {  int fd = *(int*)arg;  char buffer[FIFO_READ_SIZE + 1];  ssize_t bytes_written;int fifo_size = 0;while(1){fifo_size = fifo_getUsed(g_fifo);if(fifo_size >= FIFO_READ_SIZE){if (FIFO_READ_SIZE != fifo_read(g_fifo, buffer, FIFO_READ_SIZE)){printf("read fifo error\n");}else{write(fd, buffer, FIFO_READ_SIZE);}}else if(fifo_size >= 0){if (fifo_size != fifo_read(g_fifo, buffer, fifo_size)){printf("read fifo error\n");}else{write(fd, buffer, fifo_size);}}else{usleep(2000);}if(fifo_isEmpty(g_fifo) && g_exit) {printf("read fifo finish\n");break;}}return NULL;  
}  int main() {  pthread_t read_thread, write_thread;  int fd_in, fd_out;g_fifo = fifo_init((u32)FIFO_BUF_SIZE); // 打开输入文件和输出文件  fd_in = open("input.txt", O_RDONLY);  fd_out = open("output.txt", O_WRONLY | O_CREAT | O_TRUNC, 0666);  // 创建读文件线程和写文件线程  pthread_create(&read_thread, NULL, read_file, &fd_in);  pthread_create(&write_thread, NULL, write_file, &fd_out);  // 等待两个线程执行完毕  pthread_join(read_thread, NULL);  pthread_join(write_thread, NULL);  // 关闭文件描述符  close(fd_in);  close(fd_out);  fifo_deinit(g_fifo);return 0;  
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/198759.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

7-HDFS的文件管理

7-HDFS的文件管理

单选题 题目1&#xff1a;下列哪个属性是hdfs-site.xml中的配置&#xff1f; 选项: A fs.defaultFS B dfs.replication C mapreduce.framework.name D yarn.resourcemanager.address 答案&#xff1a;B ------------------------------ 题目2&#xff1a;HDFS默认备份数量&…
阅读更多...
fastboot常用命令

fastboot常用命令

fastboot常用命令 显示fastboot设备&#xff1a;fastboot devices 获取手机相关信息&#xff1a;fastboot getvar all 重启手机&#xff1a;fastboot reboot 重启到bootloader&#xff1a;fastboot reboot-bootloader 擦除分区&#xff1a;fastboot erase (分区名) 例&…
阅读更多...
代码随想录算法训练营第四十三天 _ 动态规划_1049.最后一块石头的重量II、494.目标和、474.一和零。

代码随想录算法训练营第四十三天 _ 动态规划_1049.最后一块石头的重量II、494.目标和、474.一和零。

学习目标&#xff1a; 动态规划五部曲&#xff1a; ① 确定dp[i]的含义 ② 求递推公式 ③ dp数组如何初始化 ④ 确定遍历顺序 ⑤ 打印递归数组 ---- 调试 引用自代码随想录&#xff01; 60天训练营打卡计划&#xff01; 学习内容&#xff1a; 1049.最后一块石头的重量II 该题…
阅读更多...
360公司-2019校招笔试-Windows开发工程师客观题合集解析

360公司-2019校招笔试-Windows开发工程师客观题合集解析

360公司-2019校招笔试-Windows开发工程师客观题合集 API无法实现进程间数据的相互传递是PostMessage2.以下代码执行后，it的数据为（异常） std::list<int> temp; std::list<int>::iterator it = temp.begin(); it = --it; 3.API在失败时的返回值跟其他不一样是 …
阅读更多...
微信小程序自定义tabBar简易实现

微信小程序自定义tabBar简易实现

文章目录 1.app.json设置custom为true开启自定义2.根目录创建自定义的tab文件3.app.js全局封装一个设置tabbar选中的方法4.在onshow中使用选中方法最终效果预览 1.app.json设置custom为true开启自定义 2.根目录创建自定义的tab文件 index.wxml <view class"tab-bar&quo…
阅读更多...
自动升降压稳压电源模块输入3v～24V输出3.3/4.2/5/9/12V芯片

自动升降压稳压电源模块输入3v～24V输出3.3/4.2/5/9/12V芯片

自动升降压稳压电源模块是一种高效、高稳定性的电源解决方案&#xff0c;广泛应用于各种需要稳定电压输出的场合。该模块采用宽电压低功耗方案&#xff0c;能够自动升降压&#xff0c;适应不同的输入电压范围&#xff0c;同时具有关断功能&#xff0c;确保设备的安全运行。 该电…
阅读更多...
Vue 报错error:0308010C:digital envelope routines::unsupported

Vue 报错error:0308010C:digital envelope routines::unsupported

因为 node.js V17版本中最近发布的OpenSSL3.0, 而OpenSSL3.0对允许算法和密钥大小增加了严格的限制 方法一 windows终端输入 set NODE_OPTIONS--openssl-legacy-provider 方法二 降低node版本&#xff0c;比如16. 方法三 package.json增加如下配置 "scripts":…
阅读更多...
想要更高效的文件传输？这些aspera替代方案可以助你一臂之力

想要更高效的文件传输？这些aspera替代方案可以助你一臂之力

随着数字化时代的不断推进&#xff0c;数据传输已成为各行各业、各类企业所必需的核心能力。而在文件传输方面&#xff0c;传统的方式往往面临着诸多问题&#xff0c;例如文件大小限制、传输速度过慢、不稳定、不安全等问题。为此&#xff0c;许多企业开始寻找更可靠、更高效的…
阅读更多...
Java大数据开发入门教程：使用Hadoop处理海量数据

Java大数据开发入门教程：使用Hadoop处理海量数据

引言&#xff1a; 随着互联网的发展和智能设备的普及&#xff0c;数据量的爆炸式增长已成为现实。如何高效地处理和分析这些海量数据成为了当今技术领域的一个重要课题。在大数据领域&#xff0c;Hadoop作为一个开源的分布式计算框架&#xff0c;被广泛应用于海量数据的存储和处…
阅读更多...
网工学习10-IP地址

网工学习10-IP地址

一、IP地址概念 IP地址是一个32位的二进制数&#xff0c;它由网络ID和主机ID两部份组成&#xff0c;用来在网络中唯一的标识的一台计算机。网络ID用来标识计算机所处的网段&#xff1b;主机ID用来标识计算机在网段中的位置。IP地址通常用4组3位十进制数表示&#xff0c;中间用…
阅读更多...
XHR 和 Fetch 的区别

XHR 和 Fetch 的区别

网站开发普遍采用前后端分离的模式&#xff0c;数据交互成为了不可或缺的关键环节。在这个过程中&#xff0c;XHR 和 Fetch API 是两种最常见的方法&#xff0c;用于从 Web 服务器获取数据。XHR 是一种传统的数据请求方式&#xff0c;而 Fetch API 则代表了现代 Web 开发的新兴…
阅读更多...
scipy笔记：scipy.interpolate.interp1d

scipy笔记：scipy.interpolate.interp1d

1 主要使用方法 class scipy.interpolate.interp1d(x, y, kindlinear, axis-1, copyTrue, bounds_errorNone, fill_valuenan, assume_sortedFalse) 2 主要函数 x一维实数值数组&#xff0c;代表插值的自变量y N维实数值数组&#xff0c;其中沿着插值轴的 y 长度必须等于 x 的…
阅读更多...
Linux：使用pv实现执行进度监控

Linux：使用pv实现执行进度监控

pv全称&#xff1a;Pipe Viewer&#xff0c;通过管道显示数据处理进度的信息 安装 yum install pv -y示例 复制文件 # 显示进度 pv data.sql > ./data-new.sql330MiB 0:00:00 [1.32GiB/s] [>] 100%限制mysql数据导出速率 mysqldump | pv -L10m > data.sql# -L, -…
阅读更多...
gitlab注册无中国区电话验证问题

gitlab注册无中国区电话验证问题

众所周知gitlab对中国区不友好&#xff0c;无法直接注册&#xff0c;页面无法选择86的手机号进行验证码发送。 Google上众多的方案是修改dom&#xff0c;而且时间大约是21年以前。 修改dom&#xff0c;对于现在的VUE、React框架来说是没有用的&#xff0c;所以不用尝试。 直接看…
阅读更多...
Docker 安装 Nacos

Docker 安装 Nacos

Docker 安装 Nacos tags: docker Nacos 文章目录 Docker 安装 Nacostags: docker Nacos 下载镜像docker 运行命令说明 Nacos 端口说明 下载镜像 下载镜像 # 搜索镜像 docker search nacos # 下载镜像 dockers pull nacos/nacos-server创建挂载文件夹 # 存放日志 mkdir naco…
阅读更多...
Linux结束程序运行的命令

Linux结束程序运行的命令

kill 通过进程 ID&#xff08;PID&#xff09;结束一个程序的运行。例如&#xff0c;要结束进程 ID 为 1234 的进程&#xff1a; kill 1234 pkill 通过进程名称结束一个程序的运行。例如&#xff0c;要结束名称为example_process的进程&#xff1a; pkill example_process …
阅读更多...
postman参数为D:\\audio\\test.mp3请求报错

postman参数为D:\\audio\\test.mp3请求报错

报错信息 报错 java.lang.IllegalArgumentException: Invalid character found in the request target [/v1/audio/transcriptions?audioPathD:\\audio\\test.mp3 ]. The valid characters are defined in RFC 7230 and RFC 3986 解决方式 yml文件上放行指定字符 relaxed-pa…
阅读更多...
Mac电脑每次修改完java的版本后，没有成功

Mac电脑每次修改完java的版本后，没有成功

问题&#xff0c;本地有多个java版本8,11,15,17但是每次执行代码后&#xff0c;版本没有变化。在环境变量文件.bash_profile中设置无效 export JAVA_HOME/Library/Java/JavaVirtualMachines/<Java版本目录>/Contents/Home 这个问题通常是由于系统默认使用的Shell不同导…
阅读更多...
安装获取mongodb

安装获取mongodb

目录 本地安装 获取云上资源 获取Atlas免费数据库 本地连接数据库 在Atlas中连接数据库 本文适合初学者或mongodb感兴趣的同学来准备学习测试环境&#xff0c;或本地临时开发环境。mongodb是一个对用户非常友好的数据库。这种友好&#xff0c;不仅仅体现在灵活的数据结构和…
阅读更多...
力扣：191. 位1的个数（Python3）

力扣：191. 位1的个数（Python3）

题目&#xff1a; 编写一个函数&#xff0c;输入是一个无符号整数&#xff08;以二进制串的形式&#xff09;&#xff0c;返回其二进制表达式中数字位数为 1 的个数&#xff08;也被称为汉明重量&#xff09;。 提示&#xff1a; 请注意&#xff0c;在某些语言&#xff08;如 J…
阅读更多...
最新文章

Copyright @ 2022~2023