百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术分析 > 正文

你真的了解epoll吗?深入epoll的五个问题

liebian365 2024-10-27 13:12 26 浏览 0 评论

由于epoll用的比较多,最近看到一些网友关于epoll的问答,所以我就想整理成一篇文章,这样看起来和理解起来都方便一些。

?问题1:什么是epoll的ET/LT模式,select/poll支持吗?

ET是edge trigger,也就是边缘触发,它是指当可读/可写事件到来时触发,重点是它只触发一次,见下图:

LT是level trigger,也就是水平触发,它是重点是可以触发多次,

代码实现实际上很简单,只有一行代码,没有想到吧。

do_epoll_wait
|--ep_poll
    |--ep_send_events
        |--ep_send_events_proc
 static __poll_t ep_send_events_proc(struct eventpoll *ep, struct list_head *head,
             void *priv)
{
    ....
    list_for_each_entry_safe(epi, tmp, head, rdllink) {
    ....
    if (epi->event.events & EPOLLONESHOT)
      epi->event.events &= EP_PRIVATE_BITS;
    //就是这句,如果不是ET,就把epi重新加入ep的就绪列表中,
    //这样下次再调用epoll_wait时,还能再就绪列表中看到这个epi,
    //然后再看看该epi是否可读。
    else if (!(epi->event.events & EPOLLET)) {
      /*
       * If this file has been added with Level
       * Trigger mode, we need to insert back inside
       * the ready list, so that the next call to
       * epoll_wait() will check again the events
       * availability. At this point, no one can insert
       * into ep->rdllist besides us. The epoll_ctl()
       * callers are locked out by
       * ep_scan_ready_list() holding "mtx" and the
       * poll callback will queue them in ep->ovflist.
       */
      list_add_tail(&epi->rdllink, &ep->rdllist);
      ep_pm_stay_awake(epi);
    }

问题2:为啥我们总建议ET触发模式跟non-block的socket一起使用呢?那能不能跟block的socket一起用呢?

  • 由于ET仅触发一次,所以很多资料都建议说ET要跟non-block的socket一起使用,很多也都没有解释原因,我来解答一下:

首先ET模式可以跟block的socket使用,没有问题,可以工作,原因是epoll只是一种让用户态知道socket是可读可写的方式或方法,epoll本身并不能影响socket本身的读写。为啥用户态要知道socket是否可读可写呢?原因是假如我们有1000个socket,每次只有两个socket是可读/可写的,这个时候我们肯定不希望遍历1000个socket,都去内核使用read/write去尝试的,我们希望内核能一次性告诉我们哪两个socket是可读/可写的。

  • 那为啥建议ET跟non-block配合使用呢?

因为有ET的特性,当告诉我们socket可读时,我们要一直读,读到没有数据为止,可是如果是block的socket的话,这个时候就会阻塞再read中,导致我们不能等待再epoll_wait中:

//伪码
while(true){
    struct epoll_event *events;
    events = (struct epoll_event *) calloc (MAXEVENTS, sizeof event);
    //如果fd是非阻塞的,就会阻塞再epoll_wait中
    int n = epoll_wait(ep, events,...);
    for(int i=0; i<n; i++){
        //如果fd是阻塞的,就会阻塞再read中
        while(read(events[i].data.fd,...) >);
    }    
}

问题3:我们能不能把一个句柄(socket)添加到不同的epoll_event中?

可以的,甚至可以把socket添加到epoll_event后,还可以使用select/poll,原因是因为sock使用一个列表来管理等待唤醒列表,当然我们可以添加多个。

|--tcp_poll
   |--sock_poll_wait
static inline void sock_poll_wait(struct file *filp, struct socket *sock,
          poll_table *p)
{
  if (!poll_does_not_wait(p)) {
     //sock->wq.wait是队列头,可以添加多个订阅者着
    poll_wait(filp, &sock->wq.wait, p);
    /* We need to be sure we are in sync with the
     * socket flags modification.
     *
     * This memory barrier is paired in the wq_has_sleeper.
     */
    smp_mb();
  }
}

我们可以构造一种使用场景,client两个线程,一个读,而另一个写同一个socket,server侧也有两个线程,同样是一个读一个写这个socket,拓扑如下:

相关视频推荐

支撑亿级io的底层基石-epoll实战揭秘

6种epoll的设计,学会了吊打面试官

手把手带你实现epoll组件,为tcp并发的实现epoll

需要C/C++ Linux服务器架构师学习资料加qun812855908获取(资料包括C/C++,Linux,golang技术,Nginx,ZeroMQ,MySQL,Redis,fastdfs,MongoDB,ZK,流媒体,CDN,P2P,K8S,Docker,TCP/IP,协程,DPDK,ffmpeg等),免费分享

问题4:EPOLLONESHOT时,如果缓冲区有未读取的数据,会立刻触发事件么?

首先我们得知道什么是EPOLLONESHOT,顾名思义就是一次性,这个一次性是指我只接收一次该fd的可读/可写等通知,后续有的话也不要通知我了,如果我再想要得到通知的话,就再使用:epoll_ctl (efd, EPOLL_CTL_ADD, fd, &event) 来添加一下。

do_epoll_wait
|--ep_poll
    |--ep_send_events
        |--ep_send_events_proc
 static __poll_t ep_send_events_proc(struct eventpoll *ep, struct list_head *head,
             void *priv)
{
    ....
    list_for_each_entry_safe(epi, tmp, head, rdllink) {
    ....
    if (epi->event.events & EPOLLONESHOT)
      //清掉EPOLLIN EPOLLOUT EPOLLERR等event
      epi->event.events &= EP_PRIVATE_BITS;

这个时候就有个问题,那就是等我调用epoll_ctl (efd, EPOLL_CTL_ADD, fd, &event)来把socket的fd添加到ep中时,那如果这个时候该socket是可读/可写的,后面我epoll_wait时能通知到我吗?

答案是:可以的。

我们来解释一下原因,

1)重设EPOLLONESHOT在前,数据到来在后,这没有问题,因为重设EPOLLONESHOT时,同时app要带原有的event标志,等数据来时,就可以放入就绪列表中了

2) 数据到来在前,重设EPOLLONESHOT在后,在重设EPOLLONESHOT时,设置完event标志后,内核会做一次poll动作,如果是就绪状态(可读、可写等),内核就把这个fd放入就绪列表中。当app重设EPOLLONESHOT时,内核会调用到下面函数:

fs/eventpoll.c
static int ep_modify(struct eventpoll *ep, struct epitem *epi,
         const struct epoll_event *event)
{
    ...
     epi->event.events = event->events; /* need barrier below */
  epi->event.data = event->data; /* protected by mtx */
        ...
                 //执行poll,
          if (ep_item_poll(epi, &pt, 1)) {
    write_lock_irq(&ep->lock);
                //如果可用且没有在就绪列表,就放入就绪列表
    if (!ep_is_linked(epi)) {
      list_add_tail(&epi->rdllink, &ep->rdllist);

le data-draft-node="block" data-draft-type="table" data-size="normal" data-row-style="normal">

这个是可以的,我们不要忘了epoll是做什么的,epoll是实现多路IO通知机制的,比如我有1000个socket,我得知道哪些是可读/可写的,然后我再去读/写它,比如下面的伪码:

while(1)
{
    int n = epoll_wait (efd, events, MAXEVENTS, -1);
    //精确知道哪个可读可写
    for(int i=0; i<n;i++)
    {
        read(events[i].data.fd,...);
    }
}

然而如果我们不使用epoll这样的通知机制我们要怎么做呢?

实际上我们也可以做,只是效率低下:

while(1)
{
    for(int i=0; i<n;i++) //不知道哪个socket是可读/可写,我们
                           //全部遍历
    {
        read(socket[i],...); //socket可以是block和non-block
    }
    sleep(1);//休息一会,避免当socket全是non-block时,持续占CPU
}

所以即使你把fd添加到epoll/select/poll中,不会影响fd的可读可写的。

总结:

相比select/poll来说epoll是比较的高效,这跟它的实现是有关的,然而select/poll的实现是简单的,目的都是相同的,都是为了实现多路IO复用,然而它们不会影响到fd(包括socket)的读写,任何使用你都可以使用write/read去读写数据的,只是你如果想在读写之前知道该fd是否可读/可写的话,就要使用select/poll/epoll。

相关推荐

go语言也可以做gui,go-fltk让你做出c++级别的桌面应用

大家都知道go语言生态并没有什么好的gui开发框架,“能用”的一个手就能数的清,好用的就更是少之又少。今天为大家推荐一个go的gui库go-fltk。它是通过cgo调用了c++的fltk库,性能非常高...

旧电脑的首选系统:TinyCore!体积小+精简+速度极快,你敢安装吗

这几天老毛桃整理了几个微型Linux发行版,准备分享给大家。要知道可供我们日常使用的Linux发行版有很多,但其中的一些发行版经常会被大家忽视。其实这些微型Linux发行版是一种非常强大的创新:在一台...

codeblocks和VS2019下的fltk使用中文

在fltk中用中文有点问题。英文是这样。中文就成这个样子了。我查了查资料,说用UTF-8编码就行了。edit->Fileencoding->UTF-8然后保存文件。看下下边的编码指示确...

FLTK(Fast Light Toolkit)一个轻量级的跨平台Python GUI库

FLTK(FastLightToolkit)是一个轻量级的跨平台GUI库,特别适用于开发需要快速、高效且简单界面的应用程序。本文将介绍Python中的FLTK库,包括其特性、应用场景以及如何通过代...

中科院开源 RISC-V 处理器“香山”流片,已成功运行 Linux

IT之家1月29日消息,去年6月份,中科院大学教授、中科院计算所研究员包云岗,发布了开源高性能RISC-V处理器核心——香山。近日,包云岗在社交平台晒出图片,香山芯片已流片,回片后...

Linux 5.13内核有望合并对苹果M1处理器支持的初步代码

预计Linux5.13将初步支持苹果SiliconM1处理器,不过完整的支持工作可能还需要几年时间才能完全完成。虽然Linux已经可以在苹果SiliconM1上运行,但这需要通过一系列的补丁才能...

Ubuntu系统下COM口测试教程(ubuntu port)

1、在待测试的板上下载minicom,下载minicom有两种方法:方法一:在Ubuntu软件中心里面搜索下载方法二:按“Ctrl+Alt+T”打开终端,打开终端后输入“sudosu”回车;在下...

湖北嵌入式软件工程师培训怎么选,让自己脱颖而出

很多年轻人毕业即失业、面试总是不如意、薪酬不满意、在家躺平。“就业难”该如何应对,参加培训是否能改变自己的职业走向,在湖北,有哪些嵌入式软件工程师培训怎么选值得推荐?粤嵌科技在嵌入式培训领域有十几年经...

新阁上位机开发---10年工程师的Modbus总结

前言我算了一下,今年是我跟Modbus相识的第10年,从最开始的简单应用到协议了解,从协议开发到协议讲解,这个陪伴了10年的协议,它一直没变,变的只是我对它的理解和认识。我一直认为Modbus协议的存...

创建你的第一个可运行的嵌入式Linux系统-5

@ZHangZMo在MicrochipBuildroot中配置QT5选择Graphic配置文件增加QT5的配置修改根文件系统支持QT5修改output/target/etc/profile配置文件...

如何在Linux下给zigbee CC2530实现上位机

0、前言网友提问如下:粉丝提问项目框架汇总下这个网友的问题,其实就是实现一个网关程序,内容分为几块:下位机,通过串口与上位机相连;下位机要能够接收上位机下发的命令,并解析这些命令;下位机能够根据这些命...

Python实现串口助手 - 03串口功能实现

 串口调试助手是最核心的当然是串口数据收发与显示的功能,pzh-py-com借助的是pySerial库实现串口收发功能,今天痞子衡为大家介绍pySerial是如何在pzh-py-com发挥功能的。一、...

为什么选择UART(串口)作为调试接口,而不是I2C、SPI等其他接口

UART(通用异步收发传输器)通常被选作调试接口有以下几个原因:简单性:协议简单:UART的协议非常简单,只需设置波特率、数据位、停止位和校验位就可以进行通信。相比之下,I2C和SPI需要处理更多的通...

同一个类,不同代码,Qt 串口类QSerialPort 与各种外设通讯处理

串口通讯在各种外设通讯中是常见接口,因为各种嵌入式CPU中串口标配,工业控制中如果不够还通过各种串口芯片进行扩展。比如spi接口的W25Q128FV.对于软件而言,因为驱动接口固定,软件也相对好写,因...

嵌入式linux为什么可以通过PC上的串口去执行命令?

1、uboot(负责初始化基本硬bai件,如串口,网卡,usb口等,然du后引导系统zhi运行)2、linux系统(真正的操作系统)3、你的应用程序(基于操作系统的软件应用)当你开发板上电时,u...

取消回复欢迎 发表评论: