并发式IO的解决方案---非阻塞式、多路复用和异步通知（异步IO）

2024-06-12 06:48
文章标签 解决方案 异步 阻塞 io 通知 多路复用 发式

本文主要是介绍并发式IO的解决方案---非阻塞式、多路复用和异步通知（异步IO），希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

---非阻塞式IO
阻塞式读取键盘和鼠标： 
    
  1. // 读取鼠标
  2. 	int fd = -1;
  3. 	char buf[200];
  4. 	
  5. 	fd = open("/dev/input/mouse1", O_RDONLY);
  6. 	if (fd < 0)
  7. 	{
  8. 		perror("open:");
  9. 		return -1;
  10. 	}
  11. 	
  12. 	memset(buf, 0, sizeof(buf));
  13. 	printf("before 鼠标 read.\n");
  14. 	read(fd, buf, 50);
  15. 	printf("鼠标读出的内容是：[%s].\n", buf);
  16. 	
  17. 	
  18. 	// 读键盘
  19. 	memset(buf, 0, sizeof(buf));
  20. 	printf("before 键盘 read.\n");
  21. 	read(0, buf, 5);
  22. 	printf("键盘读出的内容是：[%s].\n", buf);
  23. 	
  24. 	
  25. 	return 0;

实现非阻塞IO访问：O_NONBLOCK和fcntl 
    
  1. int fcntl(int fd, int cmd, ... /* arg */ );
F_GETFL (void)
Get the file access mode and the file status flags; arg is ignored.
F_SETFL (int)
Set the file status flags to  the  value  specified  by  arg.   File  access  mode
(O_RDONLY,  O_WRONLY,  O_RDWR)  and  file  creation  flags (i.e., O_CREAT, O_EXCL,
O_NOCTTY, O_TRUNC) in arg are ignored.  On Linux this command can change only  the
O_APPEND, O_ASYNC, O_DIRECT, O_NOATIME, and O_NONBLOCK flags.
属性：
O_NONBLOCK //非阻塞
O_ASYNC //接收异步IO
 
    
  1. int fd = -1;
  2. 	int flag = -1;
  3. 	char buf[200];
  4. 	int ret = -1;
  5. 	
  6. 	fd = open("/dev/input/mouse1", O_RDONLY | O_NONBLOCK);
  7. 	if (fd < 0)
  8. 	{
  9. 		perror("open:");
  10. 		return -1;
  11. 	}
  12. 	
  13. 	// 把0号文件描述符（stdin）变成非阻塞式的
  14. 	flag = fcntl(0, F_GETFL);		// 先获取原来的flag
  15. 	flag |= O_NONBLOCK;				// 添加非阻塞属性
  16. 	fcntl(0, F_SETFL, flag);		// 更新flag
  17. 	// 这3步之后，0就变成了非阻塞式的了
  18. 	
  19. 	while (1)
  20. 	{
  21. 		// 读鼠标
  22. 		memset(buf, 0, sizeof(buf));
  23. 		//printf("before 鼠标 read.\n");
  24. 		ret = read(fd, buf, 50);
  25. 		if (ret > 0)
  26. 		{
  27. 			printf("鼠标读出的内容是：[%s].\n", buf);
  28. 		}
  29. 		
  30. 		// 读键盘
  31. 		memset(buf, 0, sizeof(buf));
  32. 		//printf("before 键盘 read.\n");
  33. 		ret = read(0, buf, 5);
  34. 		if (ret > 0)
  35. 		{
  36. 			printf("键盘读出的内容是：[%s].\n", buf);
  37. 		}
  38. 	}

---多路复用IO
select和poll
外部阻塞式，内部非阻塞式自动轮询多路阻塞式IO
---select函数介绍 
     
  1. int select(int nfds, fd_set *readfds, fd_set *writefds,
  2.                   fd_set *exceptfds, struct timeval *timeout);     
  3. //nfds：多路阻塞式IO中最大的文件描述符+1
  4. //*readfds：要读的IO
  5. //*writefds：要写的IO
  6. //*exceptfds：出现错误的IO
  7. //*timeout：超时时间，在超时时间内，有IO激活函数，则立刻返回，没有IO激活，则在到达超时时间时返回
  8. //struct timeval {time_t      tv_sec;     /* seconds */suseconds_t tv_usec;    /* microseconds */};

  10. //返回值：0-超时返回   >0-返回的是IO的返回路数   -1-返回错误
select的几个宏函数： 
      
  1.        void FD_CLR(int fd, fd_set *set);              //将fd从set里面拿出去    clearO(∩_∩)O~
  2.        int  FD_ISSET(int fd, fd_set *set);             //判断fd有没有被置位，返回值是正的，说明这个fd的IO发生了，负的就没有发生
  3.        void FD_SET(int fd, fd_set *set);                //将fd添加进set里面去
  4.        void FD_ZERO(fd_set *set);                       //将所有的fd_set全部清除出去
代码实践：用select函数实现同时读取键盘鼠标 
     
  1. 	int fd = -1, ret = -1;
  2. 	char buf[200];
  3. 	fd_set myset;
  4. 	struct timeval tm;
  5. 	
  6. 	fd = open("/dev/input/mouse1", O_RDONLY);
  7. 	if (fd < 0)
  8. 	{
  9. 		perror("open:");
  10. 		return -1;
  11. 	}
  12. 	
  13. 	// 当前有2个fd，一共是fd一个是0
  14. 	// 处理myset
  15. 	FD_ZERO(&myset);
  16. 	FD_SET(fd, &myset);    //鼠标的
  17. 	FD_SET(0, &myset);     //键盘的
  18. 	
  19. 	tm.tv_sec = 10;
  20. 	tm.tv_usec = 0;
  22. 	ret = select(fd+1, &myset, NULL, NULL, &tm);       //如果两个都没有输入，程序就会在这阻塞住
  23. 	if (ret < 0)
  24. 	{
  25. 		perror("select: ");
  26. 		return -1;
  27. 	}
  28. 	else if (ret == 0)
  29. 	{
  30. 		printf("超时了\n");
  31. 	}
  32. 	else
  33. 	{
  34. 		// 等到了一路IO，然后去监测到底是哪个IO到了，处理之
  35. 		if (FD_ISSET(0, &myset))
  36. 		{
  37. 			// 这里处理键盘
  38. 			memset(buf, 0, sizeof(buf));
  39. 			read(0, buf, 5);
  40. 			printf("键盘读出的内容是：[%s].\n", buf);
  41. 		}
  42. 		
  43. 		if (FD_ISSET(fd, &myset))
  44. 		{
  45. 			// 这里处理鼠标
  46. 			memset(buf, 0, sizeof(buf));
  47. 			read(fd, buf, 50);
  48. 			printf("鼠标读出的内容是：[%s].\n", buf);
  49. 		}
  50. 	}
  52. 	return 0;


---poll函数介绍 
    
  1. int poll(struct pollfd *fds, nfds_t nfds, int timeout);
//使用前必须先设置 struct pollfd * fds 
    
  1. struct pollfd {
  2.                int   fd;         /* file descriptor */
  3.                short events;     /* requested events */
  4.                short revents;    /* returned events */ //是内核设置的
  5.            };
     
  1. events常用宏：
  2.               POLLIN     There is data to read.   //FD要读
  3.               POLLOUT     Writing now will not block.//FD要写
如果有事件发生，要判断是哪个IO发生的，就去判断每个IO的 events和revents是否相等 ，若相等就说明此IO发生
返回值和select一样；
代码实践：用poll函数实现同时读取键盘鼠标 
    
  1. // 读取鼠标
  2. 	int fd = -1, ret = -1;
  3. 	char buf[200];
  4. 	struct pollfd myfds[2] = {0};
  5. 	
  6. 	fd = open("/dev/input/mouse1", O_RDONLY);
  7. 	if (fd < 0)
  8. 	{
  9. 		perror("open:");
  10. 		return -1;
  11. 	}
  12. 	
  13. 	// 初始化我们的pollfd
  14. 	myfds[0].fd = 0;			// 键盘
  15. 	myfds[0].events = POLLIN;	// 等待读操作
  16. 	
  17. 	myfds[1].fd = fd;			// 鼠标
  18. 	myfds[1].events = POLLIN;	// 等待读操作
  20. 	ret = poll(myfds, fd+1, 10000);
  21. 	if (ret < 0)
  22. 	{
  23. 		perror("poll: ");
  24. 		return -1;
  25. 	}
  26. 	else if (ret == 0)
  27. 	{
  28. 		printf("超时了\n");
  29. 	}
  30. 	else
  31. 	{
  32. 		// 等到了一路IO，然后去监测到底是哪个IO到了，处理之
  33. 		if (myfds[0].events == myfds[0].revents)
  34. 		{
  35. 			// 这里处理键盘
  36. 			memset(buf, 0, sizeof(buf));
  37. 			read(0, buf, 5);
  38. 			printf("键盘读出的内容是：[%s].\n", buf);
  39. 		}
  40. 		
  41. 		if (myfds[1].events == myfds[1].revents)
  42. 		{
  43. 			// 这里处理鼠标
  44. 			memset(buf, 0, sizeof(buf));
  45. 			read(fd, buf, 50);
  46. 			printf("鼠标读出的内容是：[%s].\n", buf);
  47. 		}
  48. 	}
  50. 	return 0;

---异步通知（异步IO）
异步IO的工作方法是：我们当前进程注册一个异步IO事件（使用signal注册一个信号SIGIO的处理函数），然后当前进程可以正常处理自己的事情，当异步事件发生后当前进程会收到一个SIGIO信号从而执行绑定的处理函数去处理这个异步事件。
3.6.6.2、涉及的函数：
(1)fcntl（F_GETFL、F_SETFL、O_ASYNC、F_SETOWN）
(2)signal或者sigaction（SIGIO）
3.6.3.代码实践 
    
  1. int mousefd = -1;
  3. // 绑定到SIGIO信号，在函数内处理异步通知事件
  4. void func(int sig)
  5. {
  6. 	char buf[200] = {0};
  7. 	
  8. 	if (sig != SIGIO)
  9. 		return;
  11. 	read(mousefd, buf, 50);
  12. 	printf("鼠标读出的内容是：[%s].\n", buf);
  13. }
  15. int main(void)
  16. {
  17. 	// 读取鼠标
  18. 	char buf[200];
  19. 	int flag = -1;
  20. 	
  21. 	mousefd = open("/dev/input/mouse1", O_RDONLY);
  22. 	if (mousefd < 0)
  23. 	{
  24. 		perror("open:");
  25. 		return -1;
  26. 	}	
  27. 	// 把鼠标的文件描述符设置为可以接受异步IO
  28. 	flag = fcntl(mousefd, F_GETFL);
  29. 	flag |= O_ASYNC;        //接受异步IO
  30. 	fcntl(mousefd, F_SETFL, flag);
  31. 	// 把异步IO事件的接收进程设置为当前进程
  32. 	fcntl(mousefd, F_SETOWN, getpid());
  33. 	
  34. 	// 注册当前进程的SIGIO信号捕获函数
  35. 	signal(SIGIO, func);
  36. 	
  37. 	// 读键盘
  38. 	while (1)
  39. 	{
  40. 		memset(buf, 0, sizeof(buf));
  41. 		//printf("before 键盘 read.\n");
  42. 		read(0, buf, 5);
  43. 		printf("键盘读出的内容是：[%s].\n", buf);
  44. 	}
  45. 		
  46. 	return 0;
  47. }

---存储映射IO
mmap函数
LCD显示和IPC之共享内存
存储映射IO的特点
(1)共享而不是复制，减少内存操作
(2)处理大文件时效率高，小文件不划算






这篇关于并发式IO的解决方案---非阻塞式、多路复用和异步通知（异步IO）的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1053479。

相关文章

部署Vue项目到服务器后404错误的原因及解决方案

部署Vue项目到服务器后404错误的原因及解决方案

《部署Vue项目到服务器后404错误的原因及解决方案》文章介绍了Vue项目部署步骤以及404错误的解决方案,部署步骤包括构建项目、上传文件、配置Web服务器、重启Nginx和访问域名,404错误通常是... 目录一、vue项目部署步骤二、404错误原因及解决方案错误场景原因分析解决方案一、Vue项目部署步骤
阅读更多...
Android 悬浮窗开发示例((动态权限请求 | 前台服务和通知 | 悬浮窗创建 )

Android 悬浮窗开发示例((动态权限请求 | 前台服务和通知 | 悬浮窗创建 )

《Android悬浮窗开发示例((动态权限请求|前台服务和通知|悬浮窗创建)》本文介绍了Android悬浮窗的实现效果,包括动态权限请求、前台服务和通知的使用,悬浮窗权限需要动态申请并引导... 目录一、悬浮窗 动态权限请求1、动态请求权限2、悬浮窗权限说明3、检查动态权限4、申请动态权限5、权限设置完毕后
阅读更多...
在MySQL执行UPDATE语句时遇到的错误1175的解决方案

在MySQL执行UPDATE语句时遇到的错误1175的解决方案

《在MySQL执行UPDATE语句时遇到的错误1175的解决方案》MySQL安全更新模式（SafeUpdateMode）限制了UPDATE和DELETE操作,要求使用WHERE子句时必须基于主键或索引... mysql 中遇到的 Error Code: 1175 是由于启用了 安全更新模式（Safe Upd
阅读更多...
Python安装时常见报错以及解决方案

Python安装时常见报错以及解决方案

《Python安装时常见报错以及解决方案》：本文主要介绍在安装Python、配置环境变量、使用pip以及运行Python脚本时常见的错误及其解决方案,文中介绍的非常详细,需要的朋友可以参考下... 目录一、安装 python 时常见报错及解决方案（一）安装包下载失败（二）权限不足二、配置环境变量时常见报错及
阅读更多...
Java下载文件中文文件名乱码的解决方案(文件名包含很多%)

Java下载文件中文文件名乱码的解决方案(文件名包含很多%)

《Java下载文件中文文件名乱码的解决方案(文件名包含很多%)》Java下载文件时,文件名中文乱码问题通常是由于编码不正确导致的,使用`URLEncoder.encode(filepath,UTF-8... 目录Java下载文件中文文件名乱码问题一般情况下，大家都是这样为了解决这个问题最终解决总结Java下
阅读更多...
Idea实现接口的方法上无法添加@Override注解的解决方案

Idea实现接口的方法上无法添加@Override注解的解决方案

《Idea实现接口的方法上无法添加@Override注解的解决方案》文章介绍了在IDEA中实现接口方法时无法添加@Override注解的问题及其解决方法,主要步骤包括更改项目结构中的Languagel... 目录Idea实现接China编程口的方法上无法添加@javascriptOverride注解错误原因解决方
阅读更多...
异步线程traceId如何实现传递

异步线程traceId如何实现传递

《异步线程traceId如何实现传递》文章介绍了如何在异步请求中传递traceId,通过重写ThreadPoolTaskExecutor的方法和实现TaskDecorator接口来增强线程池,确保异步... 目录前言重写ThreadPoolTaskExecutor中方法线程池增强总结前言在日常问题排查中，
阅读更多...
一文详解Java Condition的await和signal等待通知机制

一文详解Java Condition的await和signal等待通知机制

《一文详解JavaCondition的await和signal等待通知机制》这篇文章主要为大家详细介绍了JavaCondition的await和signal等待通知机制的相关知识,文中的示例代码讲... 目录1. Condition的核心方法2. 使用场景与优势3. 使用流程与规范基本模板生产者-消费者示例
阅读更多...
解读Redis秒杀优化方案(阻塞队列+基于Stream流的消息队列)

解读Redis秒杀优化方案(阻塞队列+基于Stream流的消息队列)

《解读Redis秒杀优化方案(阻塞队列+基于Stream流的消息队列)》该文章介绍了使用Redis的阻塞队列和Stream流的消息队列来优化秒杀系统的方案,通过将秒杀流程拆分为两条流水线,使用Redi... 目录Redis秒杀优化方案(阻塞队列+Stream流的消息队列)什么是消息队列？消费者组的工作方式每
阅读更多...
MYSQL事务死锁问题排查及解决方案

MYSQL事务死锁问题排查及解决方案

《MYSQL事务死锁问题排查及解决方案》：本文主要介绍Java服务报错日志的情况,并通过一系列排查和优化措施,最终发现并解决了服务假死的问题,文中通过代码介绍的非常详细,需要的朋友可以参考下... 目录问题现象推测 1 - 客户端无错误重试配置推测 2 - 客户端超时时间过短推测 3 - mysql 版本问
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2