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

简介: 首先,看程序四的例子。 l 程序四 点击(此处)折叠或打开 #include unistd.

首先,看程序四的例子。

程序四


点击(此处)折叠或打开

  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=STDOUT_FILENO;
  11.     ev.events=EPOLLOUT|EPOLLET;//监听读状态同时设置ET模式
  12.     epoll_ctl(epfd,EPOLL_CTL_ADD,STDOUT_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==STDOUT_FILENO)
  19.              cout"hello world!"endl;
  20.      }
  21.    }
  22. };

这个程序的功能是只要标准输出写就绪,就输出“hello world”。

运行结果:

我们发现这将是一个死循环。下面具体分析一下这个程序的执行过程:

(1) 首先初始buffer为空,buffer中有空间可写,这时无论是ET还是LT都会将对应的epitem加入rdlist(对应第一节图中的红线),导致epoll_wait就返回写就绪。

(2) 程序想标准输出输出hello world和换行符,因为标准输出为控制台的时候缓冲是“行缓冲”,所以换行符导致buffer中的内容清空,这就对应第二节中ET模式下写就绪的第二种情况——当有旧数据被发送走时,即buffer中待写的内容变少得时候会触发fd状态的改变。所以下次epoll_wait会返回写就绪。之后重复这个过程一直循环下去。

我们再看程序五。

程序五

相对程序四这里仅仅去掉了输出的换行操作。即:

 cout

运行结果如下:

我们看到程序成挂起状态。因为第一次epoll_wait返回写就绪后,程序向标准输出的buffer中写入“hello world!”,但是因为没有输出换行,所以buffer中的内容一直存在,下次epoll_wait的时候,虽然有写空间但是ET模式下不再返回写就绪。回忆第一节关于ET的实现,这种情况原因就是第一次buffer为空,导致epitem加入rdlist,返回一次就绪后移除此epitem,之后虽然buffer仍然可写,但是由于对应epitem已经不再rdlist中,就不会对其就绪fdevents的在检测了。

程序六


点击(此处)折叠或打开

  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=STDOUT_FILENO;
  7.     ev.events=EPOLLOUT;//使用默认LT模式
  8.     epoll_ctl(epfd,EPOLL_CTL_ADD,STDOUT_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==STDOUT_FILENO)
  15.          cout"hello world!";
  16.     }
  17.    }
  18. };

程序六相对程序五仅仅是修改ET模式为默认的LT模式,我们发现程序再次死循环。这时候原因已经很清楚了,因为当向buffer写入hello world!后,虽然buffer没有输出清空,但是LT模式下只有buffer有写空间就返回写就绪,所以会一直输出hello world!,buffer满的时候,buffer会自动刷清输出,同样会造成epoll_wait返回写就绪。

程序

点击(此处)折叠或打开

  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=STDOUT_FILENO;
  7.     ev.events=EPOLLOUT|EPOLLET;//监听读状态同时设置ET模式
  8.     epoll_ctl(epfd,EPOLL_CTL_ADD,STDOUT_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==STDOUT_FILENO)
  15.            cout"hello world!";
  16.        ev.data.fd=STDOUT_FILENO;
  17.        ev.events=EPOLLOUT|EPOLLET;
  18.        epoll_ctl(epfd,EPOLL_CTL_MOD,STDOUT_FILENO,&ev); //重新MOD事件(ADD无效)
  19.    }
  20.  }
  21. };

程序七相对于程序五在每次向标准输出的buffer输出hello world!后,重新MOD OUT事件。所以相当于每次重新进行第一节中红线描述的途径返回就绪,导致程序循环输出。

    

目录
相关文章
|
4月前
|
监控 Linux API
epoll-reactor模型原理及代码解析
epoll-reactor模型原理及代码解析
58 0
|
4月前
|
Linux API C++
epoll封装reactor原理剖析与代码实现(1)
epoll封装reactor原理剖析与代码实现(1)
69 0
|
4月前
epoll分析
epoll分析
|
5月前
|
存储 Linux
Linux网络编程(epoll函数的使用)
Linux网络编程(epoll函数的使用)
49 0
|
Linux
linux开发各种I/O操作简析,以及select、poll、epoll机制的对比
linux开发各种I/O操作简析,以及select、poll、epoll机制的对比
239 1
linux开发各种I/O操作简析,以及select、poll、epoll机制的对比
彻底学会使用epoll(四)——ET的写操作实例分析
首先,看程序四的例子。 l 程序四 点击(此处)折叠或打开 #include unistd.
864 0
彻底学会使用epoll(三)——ET的读操作实例分析
首先看程序一,这个程序想要实现的功能是当用户从控制台有任何输入操作时,输出”hello world!”。 l 程序一    点击(此处)折叠或打开 #include unistd.
1064 0
彻底学会使用epoll(一)——ET模式实现分析
注:之前写过两篇关于epoll实现的文章,但是感觉懂得了实现原理并不一定会使用,所以又决定写这一系列文章,希望能够对epoll有比较清楚的认识。是请大家转载务必注明出处,算是对我劳动成果的一点点尊重吧。
1755 0
彻底学会使用epoll(六)——关于ET的若干问题总结
彻底学会使用epoll(六)——关于ET的若干问题总结 ——lvyilong316 6.1 ET模式为什么要设置在非阻塞模式下工作     因为ET模式下的读写需要一直读或写直到出错(对于读,当读到的实际字节数小于请求字节数时就可以停止),而如果你的文件描述符如果不是非阻塞的,那这个一直读或一直写势必会在最后一次阻塞。
1372 0
彻底学会使用epoll(五)—— ET模式下的注意事项
彻底学会epoll(五)—— ET模式下的注意事项 ——lvyilong316 5.1 ET模式下的读写     经过前面几节分析,我们可以知道,当epoll工作在ET模式下时,对于读操作,如果read一次没有读尽buffer中的数据,那么下次将得不到读就绪的通知,造成buffer中已有的数据无机会读出,除非有新的数据再次到达。
2281 0