文件IO——如何实现非阻塞式IO?

以下内容源于朱有鹏嵌入式课程的学习与整理,如有侵权请告知删除。

一、阻塞式IO

1、阻塞式的概念

我们知道,有些函数在调用时(比如网络编程中的recv函数),如果某些条件不满足,则会进入等待状态,直到条件满足才去执行操作并返回。这种函数就叫做阻塞式函数。在文件IO中,阻塞式函数(或者API)有wait、pause、sleep等函数。

另外,使用read或write某些文件时(read和write函数本身不是阻塞式的),文件对应的对象可能是阻塞式的,比如键盘和鼠标就是阻塞式设备

Linux系统默认使用阻塞式。

2、阻塞式的缺点

阻塞式的设计,既有它的好处,也有它的困境。它的好处是简单容易实现,有利于充分发挥CPU的性能。

它的缺点,我们用一个例子说明。上面提及,键盘和鼠标都是阻塞式设备。

1、在程序中读取键盘

比如执行下面这段代码,read函数会等待键盘输入完成(因为shell是行缓冲的,输入回车时表示输入完成,不按下回车就表示输入还没有结束),从而阻塞。

int main(void)
{// 读取键盘// 键盘就是标准输入,stdinchar buf[100];memset(buf, 0, sizeof(buf));printf("before read.\n");read(0, buf, 5);printf("读出的内容是:[%s].\n", buf);return 0;
}

2、 在程序中读取鼠标

比如执行下面这段代码。(这里我们先使用cat命令来查看使用的鼠标对应哪个文件,以便在代码中open时使用。)代码执行后,移动鼠标屏幕有数据输出。

int main(void)
{// 读取鼠标int fd = -1;char buf[200];fd = open("/dev/input/mouse1", O_RDONLY);if (fd < 0){perror("open:");return -1;}memset(buf, 0, sizeof(buf));printf("before read.\n");read(fd, buf, 50);printf("读出的内容是:[%s].\n", buf);return 0;
}

3、 在程序中同时读取鼠标与键盘

我们希望实现动键盘就显示键盘的内容,动鼠标就显示鼠标的内容。

但是下面的程序的现象却是:如果顺着程序,先鼠标再键盘则顺利显示;如果先键盘的话,会被鼠标阻塞住。

#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>int main(void)
{// 读取鼠标int fd = -1;char buf[200];fd = open("/dev/input/mouse1", O_RDONLY);if (fd < 0){perror("open:");return -1;}memset(buf, 0, sizeof(buf));printf("before 鼠标 read.\n");read(fd, buf, 50);printf("鼠标读出的内容是:[%s].\n", buf);// 读键盘memset(buf, 0, sizeof(buf));printf("before 键盘 read.\n");read(0, buf, 5);//键盘就是标准输入,stdin,用0表示,它是默认打开的。printf("键盘读出的内容是:[%s].\n", buf);return 0;
}

二、非阻塞式IO

1、实现非阻塞式IO的两种方法

如何实现非阻塞式IO呢?有两种方法:

(1)方法一:打开文件时添加O_NONBLOCK标志。

(2)方法二:普通打开文件后,使用fcntl函数设置文件描述符的属性。

2、代码示例

分别利用O_NONBLOCK标志、fcntl函数, 将上节中阻塞式的鼠标和键盘读取改为非阻塞式的。

#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>int main(void)
{// 读取鼠标int fd = -1;int flag = -1;char buf[200];int ret = -1;//方法一:利用O_NONBLOCK标志将鼠标设置为非阻塞式的  fd = open("/dev/input/mouse1", O_RDONLY | O_NONBLOCK);if (fd < 0){perror("open:");return -1;}//方法二:利用fcntl函数设置键盘为非阻塞式的                                   // 把0号文件描述符(stdin)变成非阻塞式的    flag = fcntl(0, F_GETFL);		// 先获取原来的flagflag |= O_NONBLOCK;				// 添加非阻塞属性fcntl(0, F_SETFL, flag);		// 更新flag// 这3步之后,0就变成了非阻塞式的了while (1){// 读鼠标memset(buf, 0, sizeof(buf));ret = read(fd, buf, 50);if (ret > 0){printf("鼠标读出的内容是:[%s].\n", buf);}// 读键盘memset(buf, 0, sizeof(buf));ret = read(0, buf, 5);if (ret > 0){printf("键盘读出的内容是:[%s].\n", buf);}}return 0;
}

三、并发式IO的解决方案(解决多路阻塞式IO的方案)

由上面的例子引出话题:并发式IO的解决方案,或者说多路阻塞式IO的解决方案。

比如上面的例子中,鼠标与键盘都是阻塞式的IO设备(即多路阻塞),它们可能同时启动与输入数据(即并发式)。在上面例子中,我们使用fcntl函数和O_NONBLOCK标志解决了阻塞的问题,但是性能不是很好。其实还可以利用多路复用IO、异步IO、存储映射IO来解决阻塞的问题。

1、多路复用IO

(1)方法原理

多路复用IO英文为“ IO multiplexing ”,主要用于解决多路阻塞式IO的问题。

它涉及select函数、poll函数,这两个函数的设计思想一样,只是外部特征不一样,我们可以任选其一来完成功能。

它的实现原理是:外部阻塞式(select函数本身是阻塞式的),内部自动轮询多路阻塞式IO(键盘A,鼠标B,这两者本身是阻塞式的),只要AB至少有一个输入,则select由阻塞返回。

(2)代码示例

1)比如使用select函数实现同时读取鼠标键盘。

 int select(int nfds, fd_set *readfds, fd_set *writefds,fd_set *exceptfds, struct timeval *timeout);

在代码中设置了超时时间,即阻塞时间不能太长,如果很久没有IO来激活select,则表明超时了。

#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <sys/select.h>
#include <sys/time.h>int main(void)
{// 读取鼠标int fd = -1, ret = -1;char buf[200];fd_set myset;struct timeval tm;//设置超时时间,即阻塞的时间不能太长,//如果很久都没有IO来激活select,则表明超时了。fd = open("/dev/input/mouse1", O_RDONLY);if (fd < 0){perror("open:");return -1;}// 当前有2个fd,一共是fd一个是0// 处理mysetFD_ZERO(&myset);FD_SET(fd, &myset);FD_SET(0, &myset);tm.tv_sec = 10;tm.tv_usec = 0;//+1,是因为0~fd,则共有fd+1个文件描述符ret = select(fd+1, &myset, NULL, NULL, &tm);if (ret < 0)//错误{perror("select: ");return -1;}else if (ret == 0)//表明超时{printf("超时了\n");}else//>0表示有一路IO激活了{// 等到了一路IO,然后去监测到底是哪个IO到了,处理之if (FD_ISSET(0, &myset)){// 这里处理键盘memset(buf, 0, sizeof(buf));read(0, buf, 5);printf("键盘读出的内容是:[%s].\n", buf);}if (FD_ISSET(fd, &myset)){// 这里处理鼠标memset(buf, 0, sizeof(buf));read(fd, buf, 50);printf("鼠标读出的内容是:[%s].\n", buf);}}return 0;
}

2)用poll函数实现同时读取键盘鼠标。

#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <poll.h>int main(void)
{// 读取鼠标int fd = -1, ret = -1;char buf[200];struct pollfd myfds[2] = {0};fd = open("/dev/input/mouse1", O_RDONLY);if (fd < 0){perror("open:");return -1;}// 初始化我们的pollfdmyfds[0].fd = 0;		// 键盘myfds[0].events = POLLIN;	// 等待读操作myfds[1].fd = fd;		// 鼠标myfds[1].events = POLLIN;	// 等待读操作ret = poll(myfds, fd+1, 10000);if (ret < 0){perror("poll: ");return -1;}else if (ret == 0){printf("超时了\n");}else{// 等到了一路IO,然后去监测到底是哪个IO到了,处理之if (myfds[0].events == myfds[0].revents){// 这里处理键盘memset(buf, 0, sizeof(buf));read(0, buf, 5);printf("键盘读出的内容是:[%s].\n", buf);}if (myfds[1].events == myfds[1].revents){// 这里处理鼠标memset(buf, 0, sizeof(buf));read(fd, buf, 50);printf("鼠标读出的内容是:[%s].\n", buf);}}return 0;
}

2、异步IO

(1)方法原理

几乎可以认为,异步IO就是操作系统用软件实现的一套中断响应系统。

异步IO的工作方法是:我们当前进程注册一个异步IO事件(使用signal注册一个信号SIGIO的处理函数),然后当前进程可以正常处理自己的事情,当异步事件发生后当前进程会收到一个SIGIO信号从而执行绑定的处理函数去处理这个异步事件。

主要涉及两个函数:fcntl函数(F_GETFL(获取flag)、F_SETFL、O_ASYNC(表明可以接收异步通知)、F_SETOWN(设置通知谁,一般都是通知当前进程)),以及signal或者sigaction(SIGIO)函数。

(2)代码实践

#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <signal.h>int mousefd = -1;// 绑定到SIGIO信号,在函数内处理异步通知事件
void func(int sig)
{char buf[200] = {0};if (sig != SIGIO)return;read(mousefd, buf, 50);printf("鼠标读出的内容是:[%s].\n", buf);
}int main(void)
{// 读取鼠标char buf[200];int flag = -1;mousefd = open("/dev/input/mouse1", O_RDONLY);if (mousefd < 0){perror("open:");return -1;}	// 把鼠标的文件描述符设置为可以接受异步IOflag = fcntl(mousefd, F_GETFL);flag |= O_ASYNC;fcntl(mousefd, F_SETFL, flag);// 把异步IO事件的接收进程设置为当前进程fcntl(mousefd, F_SETOWN, getpid());// 注册当前进程的SIGIO信号捕获函数signal(SIGIO, func);// 读键盘,在这里是当前进程while (1){memset(buf, 0, sizeof(buf));read(0, buf, 5);printf("键盘读出的内容是:[%s].\n", buf);}return 0;
}

3、存储映射IO

该方法体现在mmap函数,将一个文件和一段内存映射起来,比如LCD设备文件和显存的对应,比如IPC之共享内存。

由于共享而不是复制,减少内存操作,处理大文件时效率高(一般用于视频处理)。

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

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

相关文章

散点画三维曲面图_UG 复杂曲面合金零件的数控加工

随着柔性制造、机床数控技术的飞速发展&#xff0c;具有复杂、 精密、小批量、多品种的曲面零件越来越多&#xff0c;如何利用数控 加工技术高质量、高效率加工该类零部件是很有研究价值 的。 本研究利用 UG 软件对复杂曲面合金零件进行三维实 体建模、设计加工工艺过程&#x…

扫盲:php session缓存至memcached中的方法

memcached是一套分布式的快取系统&#xff0c;当初是Danga Interactive为了LiveJournal所发展的&#xff0c;但被许多软件&#xff08;如MediaWiki&#xff09;所使用。这是一套开放源代码软件&#xff0c;以BSD license授权协议发布。[1]memcached仅支持一些非常简单的命令 比…

beginner3

<!-- 生成验证码 --> <action name"rand" class"mainAction" method"rand"> <result type"stream"> //默认返回为nameSUCCESS <param name"contentType">image/jpe…

通过stream去重_stream去重

引言Spring Boot 2.0最近去了GA&#xff0c;所以我决定写我关于Spring的第一篇文章很长一段时间引言Spring Boot 2.0最近去了GA&#xff0c;所以我决定写我关于Spring的第一篇文章很长一段时间。自发布以来&#xff0c;我一直在看到越来越多的Spring WebFlux以​​及如何使用它…

文件IO——获取文件属性

以下内容源于朱有鹏嵌入式课程的学习整理与整理&#xff0c;如有侵权请告知删除。 前言 文件属性&#xff0c;包括文件的名字、创建时间、文件类型、文件权限等等内容。 本文讲述了以下内容&#xff1a; &#xff08;1&#xff09;文件类型有哪些&#xff1b; &#xff08;2&am…

使用juniversalchardet做字符编码识别

为什么80%的码农都做不了架构师&#xff1f;>>> 在抓取网站的页面的时候最烦人的一件事情之一就是识别原站点的编码&#xff0c;通常来说只有GBK&#xff08;GB2312&#xff09;和UTF8两种&#xff0c;不过依旧需要读取大量Http头信息来识别&#xff0c;有些网站则…

淘宝开放API,很不错

http://api.taobao.com/myresources/standardSdk.htm?spm0.0.0.0.YeOZMs# 转载于:https://www.cnblogs.com/tandychao/archive/2013/03/01/2938561.html

短线操作总结

今日操作很失败&#xff0c;到嘴的肉都跑了&#xff01;首先是昨日上午买入的保险股&#xff0c;下午领涨&#xff0c;由于是T1的缘故&#xff0c;只能在今天卖&#xff0c;没想到今日保险股全线熄火&#xff0c;走了一波过山车&#xff0c;至尾盘微利&#xff1b;其次是昨天下…

新人报道,写的东西还请大神们多指导!也希望能让和我一样的同事少走弯路。...

大家好&#xff01;我刚工作&#xff0c;经验还很有限&#xff0c;写的东西都是自己在工作过程中遇到的问题&#xff0c;花了很多时间来解决之后的一些总结&#xff0c;可能比较浅显也比较简单&#xff0c;有什么不足的地方还请大家指正&#xff0c;有好的方法也欢迎大家留言&a…

如何用word制作英语答题卡_英语考试答题卡(word 版)

西宁联想教育培训学校西宁联想教育培训学校第1页共1页****学校****考试模拟试卷英语卷(答题卡)(时间&#xff1a;120分钟&#xff0c;满分&#xff1a;120分)姓名&#xff1a;_______________学校&#xff1a;___________________准考证号&#xff1a;________________________…

获取系统信息1——linux系统中的时间

以下内容源于朱有鹏嵌入式课程的学习与整理&#xff0c;如有侵权请告知删除。 一、关于时间的概念 1、GMT时间 GMT是格林尼治时间&#xff0c;即格林尼治地区的当地时间。用格林尼治的当地时间作为全球国际时间&#xff0c;用以描述全球性的事件的时间&#xff0c;方便大家记忆…

hystrix 单独使用_使用Hystrix对Dubbo消费者提供线程隔离保护

在dubbo中对于消费者的保护提供了actives进行并发控制保护&#xff0c;但是功能相对薄弱&#xff0c;下面我们探讨下如何使用Netflix提供的服务容错组件Hystrix对dubo消费者提供线程隔离保护为什么需要Hystrix?在大中型分布式系统中&#xff0c;通常我们需要依赖很多dubbo服务…

二分查找(Binary Search)

1.递归实现 int binarySearchRecursive(int a[],int low,int high,int key){if(low>high)return -(low1);int midlow(high-low)/2;if(key<a[mid])return binarySearchRecursive(a,low,mid-1,key);else if(key > a[mid])return binarySearchRecursive(a,mid1,high,key)…

判断一个字符串是否为回文-链队(新建,进队,出队),链栈(新建,进栈,出栈)...

回文&#xff1a;字符对称排列的字符串&#xff0c;例如ABCBA 思路&#xff1a;根据队&#xff1a;先进先出和栈: 先进后出的原则&#xff0c;进行比较出队和出栈的字符是否相等。如果相等&#xff0c;则为回文。 创建控制台应用程序。 1 #region 字符节点类 2 …

字符设备驱动基础5——驱动如何操控硬件

以下内容源于朱有鹏嵌入式课程的学习与整理&#xff0c;如有侵权请告知删除。 补充内容&#xff1a;字符设备驱动高级篇5——静态映射表、动态映射结构体方式操作寄存器 前言 上节字符设备驱动基础4——读写接口的操作实践中&#xff0c;驱动源代码中的test_chrdev_open()、te…

Android----使用代码 建立gprs 闹钟 连接

Android&#xff1a;实用代码&#xff08;开启启动、建立GPRS连接、闹钟等&#xff09; 分类&#xff1a; Android2012-04-21 18:06312人阅读评论(0)收藏举报androidactionstringservice手机j2me1&#xff1a;查看是否有存储卡插入String statusEnvironment.getExternalStorage…

句法依存分析_复旦大学邱锡鹏教授:词法、句法分析研究进展综述

本文为第十六届自然语言处理青年学者研讨会 YSSNLP2019 报告《词法、句法分析研究进展综述》的简要文字整理&#xff0c;本报告主要回顾词法、句法领域的最新研究进展。 关于报告人&#xff1a;邱锡鹏&#xff0c;复旦大学计算机科学技术学院副教授&#xff0c;博士生导师。于复…

【struts2】Struts2的运行流程

1&#xff09;前提条件 在讲解流程之前&#xff0c;假设我们已经建立了的一个名为strutsDeepen的web工程&#xff0c;该工程仅仅实现了简单的用户登陆与欢迎界面。具体的实现为&#xff1a; 在web.xml中配置了Struts2的过滤器写了一个Action类&#xff0c;名称为loginAction在s…

获取系统信息2——linux中使用随机数

以下内容源于朱有鹏嵌入式课程的学习与整理&#xff0c;如有侵权请告知删除。 一、随机数和伪随机数 随机数是随机出现&#xff0c;没有任何规律的一组数列。真正的完全随机的数列是不存在的&#xff0c;只是一种理想情况。我们一般只能通过一些算法得到一个伪随机数序列。平时…

11. 类对象简介

11. 类对象简介1.1 类是一个模板&#xff0c;是一种类型&#xff0c;“物以类聚”1.2 对象是类的一个具体实现1.3例如&#xff1a;汽车模型和生产出来的汽车猫和我家的那只猫1.4 实例人骑车public class Test3{public static void main(String[] args){Person p new Person();…