彻底学会使用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事件不会有任何影响。

相关文章
|
8月前
|
Java
如何理解网络阻塞 I/O:BIO
如何理解网络阻塞 I/O:BIO
114 3
|
4月前
|
监控 网络协议 Linux
彻底解密:select,poll底层系统调用的核心思想原理
彻底解密:select,poll底层系统调用的核心思想原理
|
5月前
|
Ubuntu Linux
内核实验(八):实现O-NONBLOCK非阻塞读写
本文通过修改之前的内核模块代码,介绍了如何在Linux内核中实现O_NONBLOCK非阻塞读写机制,并通过在Qemu虚拟机上的测试验证了非阻塞读写操作的正确性。
80 0
内核实验(八):实现O-NONBLOCK非阻塞读写
|
7月前
|
存储 安全 网络协议
epoll的底层实现原理
epoll的底层实现原理
64 0
|
8月前
|
存储 安全 Linux
【Linux】详解进程通信中信号量的本质&&同步和互斥的概念&&临界资源和临界区的概念
【Linux】详解进程通信中信号量的本质&&同步和互斥的概念&&临界资源和临界区的概念
|
8月前
|
存储 缓存 安全
Java并发基础之互斥同步、非阻塞同步、指令重排与volatile
在Java中,多线程编程常常涉及到共享数据的访问,这时候就需要考虑线程安全问题。Java提供了多种机制来实现线程安全,其中包括互斥同步(Mutex Synchronization)、非阻塞同步(Non-blocking Synchronization)、以及volatile关键字等。 互斥同步(Mutex Synchronization) 互斥同步是一种基本的同步手段,它要求在任何时刻,只有一个线程可以执行某个方法或某个代码块,其他线程必须等待。Java中的synchronized关键字就是实现互斥同步的常用手段。当一个线程进入一个synchronized方法或代码块时,它需要先获得锁,如果
78 0
|
Linux
Linux驱动开发——并发和竞态(信号量方式的使用④)
Linux驱动开发——并发和竞态(信号量方式的使用④)
179 0
Linux驱动开发——并发和竞态(信号量方式的使用④)
阻塞I/O与非阻塞I/O之间的关系--知识点3
阻塞I/O与非阻塞I/O之间的关系--知识点3
77 0
阻塞I/O与非阻塞I/O之间的关系--知识点3
|
Java
一文读懂阻塞、非阻塞、同步、异步IO
原文:一文读懂阻塞、非阻塞、同步、异步IO 介绍     在谈及网络IO的时候总避不开阻塞、非阻塞、同步、异步、IO多路复用、select、poll、epoll等这几个词语。在面试的时候也会被经常问到这几个的区别。
5618 0
彻底学会使用epoll(三)——ET的读操作实例分析
首先看程序一,这个程序想要实现的功能是当用户从控制台有任何输入操作时,输出”hello world!”。 l 程序一    点击(此处)折叠或打开 #include unistd.
1117 0