彻底学会使用epoll(三)——ET的读操作实例分析

简介: 首先看程序一,这个程序想要实现的功能是当用户从控制台有任何输入操作时,输出”hello world!”。 l 程序一    点击(此处)折叠或打开 #include unistd.

首先看程序一,这个程序想要实现的功能是当用户从控制台有任何输入操作时,输出hello world

程序一

  

点击(此处)折叠或打开

  1. #include unistd.h>
  2. #include iostream>
  3. #include sys/epoll.h>
  4. using namespace std;
  5. int main(void)
  6. {
  7.     int epfd,nfds;
  8.     struct epoll_event ev,events[5];//ev用于注册事件,数组用于返回要处理的事件
  9.     epfd=epoll_create(1);//只需要监听一个描述符——标准输入
  10.     ev.data.fd=STDIN_FILENO;
  11.     ev.events=EPOLLIN|EPOLLET;//监听读状态同时设置ET模式
  12.     epoll_ctl(epfd,EPOLL_CTL_ADD,STDIN_FILENO,&ev);//注册epoll事件
  13.     for(;;)
  14.    {
  15.      nfds=epoll_wait(epfd,events,5,-1);
  16.      for(int i=0;infds;i++)
  17.      {
  18.         if(events[i].data.fd==STDIN_FILENO)
  19.            cout"hello world!"endl;
  20.      }
  21.    }
  22. }

运行结果:

程序一中对标准输入的监听使用ET模式,结果实现了我们想要的功能。那么实际原理是如何呢,我们将过程分析一下:

(1) 当用户输入一组字符,这组字符被送入buffer,字符停留在buffer中,又因为buffer由空变为不空,所以ET返回读就绪,输出hello world

(2) 之后程序再次执行epoll_wait,此时虽然buffer中有内容可读,但是根据我们上节的分析,ET并不返回就绪,导致epoll_wait阻塞。(底层原因是ET下就绪fdepitem只被放入rdlist一次)。

(3) 用户再次输入一组字符,导致buffer中的内容增多,根据我们上节的分析这将导致fd状态的改变,是对应的epitem再次加入rdlist,从而使epoll_wait返回读就绪,再次输出“hello world!”。

 我们在看看LT的情况如何,将程序以下修改:

    ev.events=EPOLLIN;//默认使用LT模式

运行结果:

结果正如我们所料,程序出现死循环,因为用户输入任意数据后,数据被送入buffer且没有被读出,所以LT模式下每次epoll_wait都认为buffer可读返回读就绪。导致每次都会输出hello world。下面在看程序二。

程序二


点击(此处)折叠或打开

  1. #include unistd.h>
  2. #include iostream>
  3. #include sys/epoll.h>
  4. using namespace std;
  5. int main(void)
  6. {
  7.     int epfd,nfds;
  8.     char buf[256];
  9.     struct epoll_event ev,events[5];//ev用于注册事件,数组用于返回要处理的事件
  10.     epfd=epoll_create(1);//只需要监听一个描述符——标准输入
  11.     ev.data.fd=STDIN_FILENO;
  12.     ev.events=EPOLLIN;//使用默认LT模式
  13.     epoll_ctl(epfd,EPOLL_CTL_ADD,STDIN_FILENO,&ev);//注册epoll事件
  14.     for(;;)
  15.    {
  16.      nfds=epoll_wait(epfd,events,5,-1);
  17.      for(int i=0;infds;i++)
  18.      {
  19.        if(events[i].data.fd==STDIN_FILENO)
  20.        {
  21.           read(STDIN_FILENO,buf,sizeof(buf));//将缓冲中的内容读出
  22.           cout"hello world!"endl;
  23.        }
  24.     }
  25.   }
  26. }

运行结果:

程序二依然使用LT模式,但是每次epoll_wait返回读就绪的时候我们都将buffer(缓冲)中的内容read出来,所以导致buffer再次清空,下次调用epoll_wait就会阻塞。所以能够实现我们所想要的功能——当用户从控制台有任何输入操作时,输出hello world。我们再来看看程序三。

程序三


点击(此处)折叠或打开

  1. int main(void)
  2. {
  3.     int epfd,nfds;
  4.     struct epoll_event ev,events[5];//ev用于注册事件,数组用于返回要处理的事件
  5.     epfd=epoll_create(1);//只需要监听一个描述符——标准输入
  6.     ev.data.fd=STDIN_FILENO;
  7.     ev.events=EPOLLIN|EPOLLET;//使用默认LT模式
  8.     epoll_ctl(epfd,EPOLL_CTL_ADD,STDIN_FILENO,&ev);//注册epoll事件
  9.     for(;;)
  10.    {
  11.      nfds=epoll_wait(epfd,events,5,-1);
  12.      for(int i=0;infds;i++)
  13.      {
  14.        if(events[i].data.fd==STDIN_FILENO)
  15.         {
  16.           cout"hello world!"endl;
  17.           ev.data.fd=STDIN_FILENO;
  18.           ev.events=EPOLLIN|EPOLLET;//使用默认LT模式
  19.           epoll_ctl(epfd,EPOLL_CTL_MOD,STDIN_FILENO,&ev);//重新MOD事件(ADD无效)
  20.         }
  21.      }
  22.    }
  23. }

程序三依然使用ET,但是每次读就绪后都主动的再次MOD IN事件,我们发现程序再次出现死循环,也就是每次返回读就绪。这就验证了上一节讨论ET读就绪的第三种情况。但是注意,如果我们将MOD改为ADD,将不会产生任何影响。别忘了每次ADD一个描述符都会在epitem组成的红黑树中添加一个项,我们之前已经ADD过一次,再次ADD将阻止添加,所以在次调用ADD IN事件不会有任何影响。

相关文章
系统编程之高级文件IO(十二)——阻塞和非阻塞方式读取
系统编程之高级文件IO(十二)——阻塞和非阻塞方式读取
120 0
系统编程之高级文件IO(十二)——阻塞和非阻塞方式读取
阻塞I/O与非阻塞I/O之间的关系--知识点3
阻塞I/O与非阻塞I/O之间的关系--知识点3
49 0
阻塞I/O与非阻塞I/O之间的关系--知识点3
|
Java
一文读懂阻塞、非阻塞、同步、异步IO
原文:一文读懂阻塞、非阻塞、同步、异步IO 介绍     在谈及网络IO的时候总避不开阻塞、非阻塞、同步、异步、IO多路复用、select、poll、epoll等这几个词语。在面试的时候也会被经常问到这几个的区别。
5427 0
|
Python 安全 C++
python多线程同步实例分析
python多线程同步实例分析进程之间通信与线程同步是一个历久弥新的话题,对编程稍有了解应该都知道,但是细说又说不清。一方面除了工作中可能用的比较少,另一方面就是这些概念牵涉到的东西比较多,而且相对较深。
1052 0
彻底学会使用epoll(三)——ET的读操作实例分析
首先看程序一,这个程序想要实现的功能是当用户从控制台有任何输入操作时,输出”hello world!”。 l 程序一    点击(此处)折叠或打开 #include unistd.
1067 0
彻底学会使用epoll(四)——ET的写操作实例分析
首先,看程序四的例子。 l 程序四 点击(此处)折叠或打开 #include unistd.
1058 0
彻底学会使用epoll(五)—— ET模式下的注意事项
彻底学会epoll(五)—— ET模式下的注意事项 ——lvyilong316 5.1 ET模式下的读写     经过前面几节分析,我们可以知道,当epoll工作在ET模式下时,对于读操作,如果read一次没有读尽buffer中的数据,那么下次将得不到读就绪的通知,造成buffer中已有的数据无机会读出,除非有新的数据再次到达。
2281 0
彻底学会使用epoll(六)——关于ET的若干问题总结
彻底学会使用epoll(六)——关于ET的若干问题总结 ——lvyilong316 6.1 ET模式为什么要设置在非阻塞模式下工作     因为ET模式下的读写需要一直读或写直到出错(对于读,当读到的实际字节数小于请求字节数时就可以停止),而如果你的文件描述符如果不是非阻塞的,那这个一直读或一直写势必会在最后一次阻塞。
1372 0