eventfd以及epoll原理分析

这两天公司代码中用到了epoll。然后在跟同事闲扯的过程中发现了Linux中有eventfd。两者虽然名字看起来差不多,但是相关性倒是不多。
为了弄明白这两个东西到底在内核上是怎么实现的,这两天将内核这两个部分的相关代码看了下,也终于明白了这两个东西的实现机制。
后续几篇博客我尽量将这两个东西的工作原理阐述清楚,但是自己的语言表达能力比较差,也只能是尽量了。

今天这篇博客首先是介绍两者的使用方式,恰巧两者能够在一个程序中搞定,我就写了下面的小程序来展示两者的功能。
  1. #include <stdio.h>
  2. #include <unistd.h>
  3. #include <sys/time.h>
  4. #include <stdint.h>
  5. #include <pthread.h>
  6. #include <sys/eventfd.h>
  7. #include <sys/epoll.h>

  8. int efd = -1;

  9. void *read_thread(void *dummy)
  10. {
  11.     int ret = 0;
  12.     uint64_t count = 0;
  13.     int ep_fd = -1;
  14.     struct epoll_event events[10];

  15.     if (efd < 0)
  16.     {
  17.         printf("efd not inited.\n");
  18.         goto fail;
  19.     }

  20.     ep_fd = epoll_create(1024);
  21.     if (ep_fd < 0)
  22.     {
  23.         perror("epoll_create fail: ");
  24.         goto fail;
  25.     }

  26.     {
  27.         struct epoll_event read_event;

  28.         read_event.events = EPOLLHUP | EPOLLERR | EPOLLIN;
  29.         read_event.data.fd = efd;

  30.         ret = epoll_ctl(ep_fd, EPOLL_CTL_ADD, efd, &read_event);
  31.         if (ret < 0)
  32.         {
  33.             perror("epoll ctl failed:");
  34.             goto fail;
  35.         }
  36.     }

  37.     while (1)
  38.     {
  39.         ret = epoll_wait(ep_fd, &events[0], 10, 5000);
  40.         if (ret > 0)
  41.         {
  42.             int i = 0;
  43.             for (; i < ret; i++)
  44.             {
  45.                 if (events[i].events & EPOLLHUP)
  46.                 {
  47.                     printf("epoll eventfd has epoll hup.\n");
  48.                     goto fail;
  49.                 }
  50.                 else if (events[i].events & EPOLLERR)
  51.                 {
  52.                     printf("epoll eventfd has epoll error.\n");
  53.                     goto fail;
  54.                 }
  55.                 else if (events[i].events & EPOLLIN)
  56.                 {
  57.                     int event_fd = events[i].data.fd;
  58.                     ret = read(event_fd, &count, sizeof(count));
  59.                     if (ret < 0)
  60.                     {
  61.                         perror("read fail:");
  62.                         goto fail;
  63.                     }
  64.                     else
  65.                     {
  66.                         struct timeval tv;

  67.                         gettimeofday(&tv, NULL);
  68.                         printf("success read from efd, read %d bytes(%llu) at %lds %ldus\n",
  69.                                ret, count, tv.tv_sec, tv.tv_usec);
  70.                     }
  71.                 }
  72.             }
  73.         }
  74.         else if (ret == 0)
  75.         {
  76.             /* time out */
  77.             printf("epoll wait timed out.\n");
  78.             break;
  79.         }
  80.         else
  81.         {
  82.             perror("epoll wait error:");
  83.             goto fail;
  84.         }
  85.     }

  86. fail:
  87.     if (ep_fd >= 0)
  88.     {
  89.         close(ep_fd);
  90.         ep_fd = -1;
  91.     }

  92.     return NULL;
  93. }

  94. int main(int argc, char *argv[])
  95. {
  96.     pthread_t pid = 0;
  97.     uint64_t count = 0;
  98.     int ret = 0;
  99.     int i = 0;

  100.     efd = eventfd(0, 0);
  101.     if (efd < 0)
  102.     {
  103.         perror("eventfd failed.");
  104.         goto fail;
  105.     }

  106.     ret = pthread_create(&pid, NULL, read_thread, NULL);
  107.     if (ret < 0)
  108.     {
  109.         perror("pthread create:");
  110.         goto fail;
  111.     }

  112.     for (i = 0; i < 5; i++)
  113.     {
  114.         count = 4;
  115.         ret = write(efd, &count, sizeof(count));
  116.         if (ret < 0)
  117.         {
  118.             perror("write event fd fail:");
  119.             goto fail;
  120.         }
  121.         else
  122.         {
  123.             struct timeval tv;

  124.             gettimeofday(&tv, NULL);
  125.             printf("success write to efd, write %d bytes(%llu) at %lds %ldus\n",
  126.                    ret, count, tv.tv_sec, tv.tv_usec);
  127.         }

  128.         sleep(1);
  129.     }

  130. fail:
  131.     if (0 != pid)
  132.     {
  133.         pthread_join(pid, NULL);
  134.         pid = 0;
  135.     }

  136.     if (efd >= 0)
  137.     {
  138.         close(efd);
  139.         efd = -1;
  140.     }
  141.     return ret;
  142. }

  1. gcc main.c -Werror -Wall -lpthread
最后执行效果为
  1. success write to efd, write 8 bytes(4) at 1328805612s 21939us
  2. success read from efd, read 8 bytes(4) at 1328805612s 21997us
  3. success write to efd, write 8 bytes(4) at 1328805613s 22247us
  4. success read from efd, read 8 bytes(4) at 1328805613s 22287us
  5. success write to efd, write 8 bytes(4) at 1328805614s 22462us
  6. success read from efd, read 8 bytes(4) at 1328805614s 22503us
  7. success write to efd, write 8 bytes(4) at 1328805615s 22688us
  8. success read from efd, read 8 bytes(4) at 1328805615s 22726us
  9. success write to efd, write 8 bytes(4) at 1328805616s 22973us
  10. success read from efd, read 8 bytes(4) at 1328805616s 23007us
  11. epoll wait timed out.
eventfd具体与pipe有点像,用来完成两个线程之间事件触发,但是同事说现在已经支持到进程级别,现在我还没有验证过。能够用来作为线程之间简单通讯,类似于pthread_cond_t。
epoll则是linux提供的一种多路复用技术,完成与select,poll等一样的功能,完成对多个文件描述符进行等待。本文上述代码仅仅用到了一个文件描述符。
epoll比select的优势网络随处可见,这就不多说了。

应用程序就已经写到这了,对于内核里面具体是怎么搞的,将会在以后的博客中尽量解释清楚。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/433507.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

一个数据包大小是多少k_算法交流: 6046 数据包的调度机制 【2.6基本算法之动态规划】...

【题目描述】 6046 数据包的调度机制 By OIer14wa随着 Internet的迅猛发展,多媒体技术和电子商务应用日益广泛,Internet上的服务质量(QoS,Qualityof Service)问题已越来越受到重视。网络中采用的数据包调度机制与网络的服务质量 QoS 有着密切的关系。研究表明传统的基于队列的调…

iOS vs. Android,应用设计该如何对症下药?

摘要&#xff1a;从iOS到Android&#xff0c;两大平台应用设计有何不同&#xff1f;又都存在什么样的问题&#xff1f;Android定制性太高&#xff0c;该如何进行UI设计&#xff1f;在CMDN CLUB第28期活动中&#xff0c;咕咚网高级产品经理王磊&#xff0c;从iOS、Android谈起&a…

postman数据保存在哪里_Postman 历史记录导出的解决方案

Postman 可以说是我在 CTF 中使用最多的工具了。它确实非常好用,但我并没有完全掌握它的使用之道,因此大量的历史请求堆在一起,显得环境无比混乱。 虽说是有想要改变的想法,但这些历史记录还是非常重要的,一时间难以割舍。于是便开始寻找导出的方案。 indexedDB 我们知道,…

cs8900a网卡驱动--寄存器

1. CS8900内部有一个4k的RAM用于访问其内部寄存器&#xff0c;称为PacketPage。 2. LineCTL 网卡状态设置 从上图看到&#xff0c;此寄存器的6&#xff0c;7位用于设置网卡的收发使能。8&#xff0c;9位用于设置网卡状态。是10BASE-T还是 AUI。下面这图更详细介绍了8&…

python输入序列语句_Python基础教程(一) - 序列:字符串、列表和元组

这一章我们主要研究这样一些类型&#xff0c;他们的成员是有序排列的&#xff0c;并且可以通过下标偏移量访问的&#xff0c;这类Python类型统称为序列&#xff0c;包括字符串、列表和元组。序列类型操作符成员关系操作符(in、not in)&#xff1a;成员关系操作符是用来判断一个…

由于找不到openni2_Kinect开发教程八:OpenNI2显示深度、彩色及融合图像

在《Kinect开发教程二&#xff1a;OpenNI读取深度图像与彩色图像并显示》中&#xff0c;小斤介绍了OpenNI读取深度与彩色图像数据的方法&#xff0c;并且借助OpenCV进行显示。OpenNI2在接口上与OpenNI有了较大变化&#xff0c;具体更新可以查看《OpenNI Migration Guide》。从获…

目录服务用户OSX: ARD的基于目录服务用户权限

改章节笔者在上海游玩的时候突然想到的...今天就有想写几篇关于目录服务用户的笔记&#xff0c;所以回家到以后就奋笔疾书的写出来发布了 从Apple Remote Desktop 3.3开始, 加入了对目录服务用户/用户组的支持, 也就是说可以利用目录用户/用户组, 来定义该用户/用户组的ARD权限…

__builtin_expect详解

在GTK2.0源码中有很多这样的宏&#xff1a;G_LIKELY和G_UNLIKELY。比如下面这段代码&#xff1a; if (G_LIKELY (acat 1)) /* allocate through magazine layer */ { ThreadMemory *tmem thread_memory_from_self(); guint ix SLAB_INDEX (allocat…

python3界面实例_程序人生——python3下tkinter的界面示例

# written by wangluojisuanimport tkinterfrom tkinter import messageboxglobal main_formglobal lbl_nameglobal entry_nameglobal entry_text_varglobal chk_varglobal chkglobal text_areadef window_quit():if tkinter.messagebox.askyesno("提示", "退出…

jQuery图表插件 JS Charts

JS Charts 是一款免费的基于javascript的轻量级插件&#xff0c;用JS Charts 绘制图表是很轻松地事,因为你只需要关心客户端的脚本。 Loading...Loading...Loading...Loading...Loading...Loading...Loading...Loading...Loading...Loading...Loading...转载于:https://www.cnb…

python官方文档怎么用_python帮助文档怎么使用

在python命令行中输入help()&#xff0c;然后再次输入time&#xff0c;可以获得很详细的模块文档&#xff1b;或者输入time.localtime&#xff0c;可以获得简略的函数参数显示&#xff1b;或者输入range&#xff0c;可以获得很详细的类的文档。方法一在python命令行输入以下内容…

ACCEPT

ACCEPT 章节&#xff1a;Linux 程序员手册 (2)更新&#xff1a;2010-09-10到 易美翻译 翻译名字 accept - 通过套接口接受一个连接 概要 #include Esys/types.h> /* 参看 “注意小节” */ #include Esys/socket.h>int accept(int sockfd, struct sockaddr *addr, sockl…

使用正则把数字前面的符号替换_正则表达式(一) 基本表达式

定义 正则表达式(Regular Expression)用某种模式去匹配一类字符串的公式&#xff0c;主要用来描述字符串匹配的工具。 匹配文本或字符存在不止一个部分满足给定的正则表达式&#xff0c;这是每一个这样的部分都被称为一个匹配。 匹配分为以下三种类型&#xff1a; 形容词性的匹…

解构给默认值_ES6学习 --函数参数默认值与解构赋值默认值

1. ES6的解构ES6中引入了解构赋值的操作&#xff0c;其作用是&#xff1a;将值从数组Array或属性从对象Object提取到不同的变量中即分为两种情况&#xff1a;从数组Array中解构&#xff0c;以及从对象Object中解构①.从数组中解构const [a, b] [1, 2]//a 1, b 2当然这些是基…

jsp思维导图_2019年经济法基础思维导图

参加2019年初级考试的考生们明天可以打印准考证啦时间&#xff1a;2019.4.26-5.5日(传送门&#xff1a;http://kjbm8.mof.gov.cn/ksbm/usercxzkz.jsp)为了帮助大家快速梳理教材考点&#xff0c;下面蓝星职业教育为大家整理了初级会计职称考试各章节思维导图&#xff0c;希望给大…

海量数据持久层解决方案_爱数AnyBackup重磅发布海量非结构化数据超可用解决方案...

海量非结构化数据有三大备份恢复问题一直没有得到有效解决&#xff1a;备份慢、恢复慢、备份数据不可查询。这三大问题已经对行业数字化转型造成了重大阻碍。今天&#xff0c;AnyBackup Family 7线上发布会——重磅发布海量非结构化数据超可用解决方案。AnyBackup以创新超可用技…

【PHP】伪静态 - 1. 使用正则表达式实现

在我们实际开发中&#xff0c;有需要&#xff0c;不希望使用真静态&#xff0c;但是希望利于SEO, 可以考虑使用伪静态。 http://localhost/news.php?typemusic&id100 我们希望这个地址可以用下面的访问url来替换 http://localhost/new-music-id100.html 上面的问题可以使用…

wpf 使子ui元素可视区域不超过父元素_对游戏UI设计的一点思考

UI决定了一个游戏的初体验&#xff0c;甚至决定了玩家的初始留存&#xff0c;甚至可以说决定了一个游戏的品质&#xff0c;虽然看起来是表象的&#xff0c;却是直指游戏核心的。简单讲&#xff0c;玩家认可一款游戏永远都是造型场景好&#xff0c;剧情好&#xff0c;画质棒&…

linux新的API signalfd、timerfd、eventfd使用说明

三种新的fd加入linux内核的的版本&#xff1a; signalfd&#xff1a;2.6.22 timerfd&#xff1a;2.6.25 eventfd&#xff1a;2.6.22 三种fd的意义&#xff1a; signalfd&#xff1a;传统的处理信号的方式是注册信号处理函数&#xff1b;由于信号是异步发生的&#xff0c;要…

grpc入门到精通_Spring Cloud 从入门到精通(一)Nacos 服务中心初探

点击上方蓝色“Java精选”&#xff0c;选择“设为星标”技术文章第一时间送达&#xff01;什么是Nacos&#xff1f;Nacos是阿里巴巴开源的项目&#xff0c;是一个更易于帮助构建云原生应用的动态服务发现、配置管理和服务管理平台。Nacos英文全称是Dynamic Naming and Configur…