定时器timerfd

1.为什么要加入此定时器接口

linux2.6.25版本新增了timerfd这个供用户程序使用的定时接口,这个接口基于文件描述符,当超时事件发生时,该文件描述符就变为可读。我首次接触这个新特性是在muduo网络库的定时器里看到的,那么新增一个这样的定时器接口有什么意义呢?

要说明这个问题我得先给大家列举一下Linux下能实现定时功能的各个接口,然后通过逐一比较来说明原因

linux下的定时接口主要有如下几种

  1. .sleep()

  2. .alarm()

  3. .usleep()

  4. .nanosleep()

  5. .clock_nanosleep()

  6. .getitimer()/setitimer()

  7. .timer_create()/timer_settime/timer_gettime()/timer_delete()

  8. .timerfd_create()/timerfd_gettime()/timer_settime()

以上便是Linux下常用的一些定时接口 
1.前三种sleep()/alarm()/usleep()在实现时可能用了SIGALRM信号,在多线程中使用信号是相当麻烦的 
2.nanosleep()/clock_nanosleep()会让线程挂起,这样会使程序失去响应,多线程网络编程中我们应该避免这样做 
3.getitimer()/timer_cteate()也是用信号来deliver超时

而我们的timerfd_create()把时间变成了一个文件描述符,该文件描述符会在超时时变得可读,这种特性可以使我们在写服务器程序时,很方便的便把定时事件变成和其他I/O事件一样的处理方式,并且此定时接口的精度也足够的高,所以我们只要以后在写I/O框架时用到了定时器就该首选timerfd_create()

2.timerfd的接口介绍

(1)timerfd的创建

 
  1. int timer_create(int clockid,int flags);

  2.  
  3. //成功返回0

 

第一个参数一般为CLOCK_REALTIME或者CLOCK_MONOTONIC,其参数意义为参数意义

CLOCK_REALTIME:相对时间,从1970.1.1到目前时间,之所以说其为相对时间,是因为我们只要改变当前系统的时间,从1970.1.1到当前时间就会发生变化,所以说其为相对时间

CLOCK_MONOTONIC:与CLOCK_REALTIME相反,它是以绝对时间为准,获取的时间为系统最近一次重启到现在的时间,更该系统时间对其没影响

第二个参数为控制标志:TFD_NONBLOCK(非阻塞),TFD_CLOEXEC(同O_CLOEXEC)

(2)定时器的设置

 
  1. int timerfd_settime(int fd,int flags

  2. const struct itimerspec *new_value

  3. struct itimerspec *old_value);

  4. //成功返回0

 

该函数的功能为启动和停止定时器,第一个参数fd为上面的timerfd_create()函数返回的定时器文件描述符,第二个参数flags为0表示相对定时器,为TFD_TIMER_ABSTIME表示绝对定时器,第三个参数new_value用来设置超时时间,为0表示停止定时器,第四个参数为原来的超时时间,一般设为NULL

需要注意的是我们可以通过clock_gettime获取当前时间,如果是绝对定时器,那么我们得获取1970.1.1到当前时间(CLOCK_REALTIME),在加上我们自己定的定时时间。若是相对定时,则要获取我们系统本次开机到目前的时间加我们要定的时常(即获取CLOCK_MONOTONIC时间)

上述参数中itimerspec的结构定义如下

 
  1. struct itimerspec {

  2. struct timespec it_interval; /* Interval for periodic timer */

  3. struct timespec it_value; /* Initial expiration */

  4. };

 

其中it_value保存首次超时时间值,即在哪个时间点超时的那个时间的值,it_interval为后续周期性超时的时间间隔,注意是时间间隔不是时间值啦 
timespec的结构定义如下

 
  1. struct timespec {

  2. time_t tv_sec; /* Seconds */

  3. long tv_nsec; /* Nanoseconds */

  4. };

 

需要注意的是当设置定时器后,我们就可以用read读取定时器的文件描述符了,当其可读时,就是超时发生的时间,下面的实例中给出用法,请读者仔细体会

3.具体实例

以绝对超时为例

 
  1. #include <sys/timerfd.h>

  2. #include <time.h>

  3. #include <unistd.h>

  4. #include <stdlib.h>

  5. #include <stdio.h>

  6. #include <stdint.h> /* Definition of uint64_t */

  7.  
  8. #define handle_error(msg) \

  9. do { perror(msg); exit(EXIT_FAILURE); } while (0)

  10.  
  11.  
  12. //打印当前定时距首次开始计时的时间

  13. static void print_elapsed_time(void)

  14. {

  15. static struct timespec start;

  16. struct timespec curr;

  17. static int first_call = 1;

  18. int secs, nsecs;

  19.  
  20. if (first_call) { //获取开始时间

  21. first_call = 0;

  22. if (clock_gettime(CLOCK_MONOTONIC, &start) == -1)

  23. handle_error("clock_gettime");

  24. }

  25.  
  26. if (clock_gettime(CLOCK_MONOTONIC, &curr) == -1)

  27. handle_error("clock_gettime");

  28.  
  29. //时间差等于每次的当前时间减去start的开始时间

  30. secs = curr.tv_sec - start.tv_sec;

  31. nsecs = curr.tv_nsec - start.tv_nsec;

  32. if (nsecs < 0) {

  33. secs--;

  34. nsecs += 1000000000; //相差的纳秒数

  35. }

  36. printf("%d.%03d: ", secs, (nsecs + 500000) / 1000000);

  37. }

  38.  
  39.  
  40. int main(int argc, char *argv[])

  41. {

  42. struct itimerspec new_value;

  43. int max_exp, fd;

  44. struct timespec now;

  45. uint64_t exp, tot_exp;

  46. ssize_t s;

  47.  
  48. if ((argc != 2) && (argc != 4)) {

  49. fprintf(stderr, "%s init-secs [interval-secs max-exp]\n",

  50. argv[0]);

  51. exit(EXIT_FAILURE);

  52. }

  53.  
  54. if (clock_gettime(CLOCK_REALTIME, &now) == -1)

  55. handle_error("clock_gettime");

  56.  
  57. /* Create a CLOCK_REALTIME absolute timer with initial

  58. expiration and interval as specified in command line */

  59.  
  60. new_value.it_value.tv_sec = now.tv_sec + atoi(argv[1]);

  61. new_value.it_value.tv_nsec = now.tv_nsec;

  62. if (argc == 2) {

  63. new_value.it_interval.tv_sec = 0;

  64. max_exp = 1;

  65. } else {

  66. new_value.it_interval.tv_sec = atoi(argv[2]); //之后的定时间隔

  67. max_exp = atoi(argv[3]); //定时总次数

  68. }

  69. new_value.it_interval.tv_nsec = 0;

  70.  
  71. //生成与定时器关联的文件描述符

  72. fd = timerfd_create(CLOCK_REALTIME, 0);

  73. if (fd == -1)

  74. handle_error("timerfd_create");

  75. if (timerfd_settime(fd, TFD_TIMER_ABSTIME, &new_value, NULL) == -1)

  76. handle_error("timerfd_settime");

  77.  
  78. //获取并打印首次首次定时开始的时间

  79. print_elapsed_time();

  80. printf("timer started\n");

  81.  
  82. for (tot_exp = 0; tot_exp < max_exp;) {

  83. s = read(fd, &exp, sizeof(uint64_t)); //read阻塞等待知道超时发生

  84. if (s != sizeof(uint64_t))

  85. handle_error("read");

  86.  
  87. tot_exp += exp;

  88. print_elapsed_time();

  89. printf("read: %llu; total=%llu\n",

  90. (unsigned long long) exp,

  91. (unsigned long long) tot_exp);

  92. }

  93.  
  94. exit(EXIT_SUCCESS);

  95. }

 

 

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

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

相关文章

timerfd与epoll

linux timerfd系列函数总结 网上关于timerfd的文章很多&#xff0c;在这儿归纳总结一下方便以后使用&#xff0c;顺便贴出一个timerfd配合epoll使用的简单例子 一、timerfd系列函数 timerfd是Linux为用户程序提供的一个定时器接口。这个接口基于文件描述符&#xff0c;通过文…

linux僵尸进程产生的原因以及如何避免产生僵尸进程defunct

给进程设置僵尸状态的目的是维护子进程的信息&#xff0c;以便父进程在以后某个时间获取。这些信息包括子进程的进程ID、终止状态以及资源利用信息(CPU时间&#xff0c;内存使用量等等)。如果一个进程终止&#xff0c;而该进程有子进程处于僵尸状态&#xff0c;那么它的所有僵尸…

linux下僵尸进程(Defunct进程)的产生与避免

在测试基于 DirectFBGstreamer 的视频联播系统的一个 Demo 的时候&#xff0c;其中大量使用 system 调用的语句&#xff0c;例如在 menu 代码中的 system("./play") &#xff0c;而且多次执行&#xff0c;这种情况下&#xff0c;在 ps -ef 列表中出现了大量的 defunc…

读过的最好的epoll讲解

首先我们来定义流的概念&#xff0c;一个流可以是文件&#xff0c;socket&#xff0c;pipe等等可以进行I/O操作的内核对象。 不管是文件&#xff0c;还是套接字&#xff0c;还是管道&#xff0c;我们都可以把他们看作流。 之后我们来讨论I/O的操作&#xff0c;通过read&#xf…

C语言指针转换为intptr_t类型

C语言指针转换为intptr_t类型 1、前言 今天在看代码时&#xff0c;发现将之一个指针赋值给一个intptr_t类型的变量。由于之前没有见过intptr_t这样数据类型&#xff0c;凭感觉认为intptr_t是int类型的指针。感觉很奇怪&#xff0c;为何要将一个指针这样做呢&#xff1f;如是果…

北京加密机现场select问题

问题描述 北京项目通过调用我们提供的库libsigxt.a与加密机通信&#xff0c;c/s架构&#xff0c;客户端启用多个线程&#xff0c;每个线程流程有以下三步&#xff0c;连接加密机&#xff0c;签名&#xff0c;关闭链接。在正常运行一段时间后会出现不能连接加密机服务问题。 连…

处理SIGCHLD信号

在上一讲中&#xff0c;我们使用fork函数得到了一个简单的并发服务器。然而&#xff0c;这样的程序有一个问题&#xff0c;就是当子进程终止时&#xff0c;会向父进程发送一个SIGCHLD信号&#xff0c;父进程默认忽略&#xff0c;导致子进程变成一个僵尸进程。僵尸进程一定要处理…

nginx源码阅读(一).综述

前言 nginx作为一款开源的轻量级高性能web服务器,是非常值得立志从事服务端开发方向的人学习的。现今nginx的最新版本是nginx-1.13.6,代码量也日渐庞大,但是由于其核心思想并没改变,为了降低阅读难度,我选择的是nginx-1.0.15版本,并且由于时间和水平有限,重点关注的是nginx的启…

系统级性能分析工具perf的介绍与使用

系统级性能优化通常包括两个阶段&#xff1a;性能剖析&#xff08;performance profiling&#xff09;和代码优化。 性能剖析的目标是寻找性能瓶颈&#xff0c;查找引发性能问题的原因及热点代码。 代码优化的目标是针对具体性能问题而优化代码或编译选项&#xff0c;以改善软…

C/C++内存问题检查利器——Purify

C&#xff0f;C内存问题检查利器——Purify 一、 引言 我们都知道软件的测试&#xff08;在以产品为主的软件公司中叫做QA—Quality Assessment&#xff09;占了整个软件工程的30% -50%&#xff0c;但有这么一种说法&#xff0c;即使是最优秀测试专家设计出来的测试…

浅析三种特殊进程:孤儿进程,僵尸进程和守护进程

其实有时想想linux内核的设计也蕴含着很多人生哲学,在linux中有这么几个特殊进程中,我们一开始见到它们的名字可能还会觉得很诧异,但在了解完了原理后,我们仔细想想,这样的命名也不无道理!下面我就给大家分别介绍一下这三种特殊的进程! 1.孤儿进程 如果父进程先退出,子进程还没…

差生文具多之(二): perf

栈回溯和符号解析是使用 perf 的两大阻力&#xff0c;本文以应用程序 fio 的观测为例子&#xff0c;提供一些处理它们的经验法则&#xff0c;希望帮助大家无痛使用 perf。 前言 系统级性能优化通常包括两个阶段&#xff1a;性能剖析和代码优化&#xff1a; 性能剖析的目标是寻…

Linux下的I/O复用与epoll详解(ET与LT)

前言 I/O多路复用有很多种实现。在linux上&#xff0c;2.4内核前主要是select和poll&#xff0c;自Linux 2.6内核正式引入epoll以来&#xff0c;epoll已经成为了目前实现高性能网络服务器的必备技术。尽管他们的使用方法不尽相同&#xff0c;但是本质上却没有什么区别。本文将重…

彻底学会使用epoll(一)——ET模式实现分析

注&#xff1a;之前写过两篇关于epoll实现的文章&#xff0c;但是感觉懂得了实现原理并不一定会使用&#xff0c;所以又决定写这一系列文章&#xff0c;希望能够对epoll有比较清楚的认识。是请大家转载务必注明出处&#xff0c;算是对我劳动成果的一点点尊重吧。另外&#xff0…

sys/queue.h分析(图片复制不过来,查看原文)

这两天有兴趣学习使用了下系统头文件sys/queue.h中的链表/队列的实现&#xff0c;感觉实现的很是优美&#xff0c;关键是以后再也不需要自己实现这些基本的数据结构了&#xff0c;哈哈&#xff01; 我的系统环境是 正好需要使用队列&#xff0c;那么本篇就以其中的尾队列&…

线程池原理及C语言实现线程池

备注&#xff1a;该线程池源码参考自传直播客培训视频配套资料&#xff1b; 源码&#xff1a;https://pan.baidu.com/s/1zWuoE3q0KT5TUjmPKTb1lw 密码&#xff1a;pp42 引言&#xff1a;线程池是一种多线程处理形式&#xff0c;大多用于高并发服务器上&#xff0c;它能合理有效…

iptables 的mangle表

mangle表的主要功能是根据规则修改数据包的一些标志位&#xff0c;以便其他规则或程序可以利用这种标志对数据包进行过滤或策略路由。 内网的客户机通过Linux主机连入Internet&#xff0c;而Linux主机与Internet连接时有两条线路&#xff0c;它们的网关如图所示。现要求对内网进…

Linux之静态库

命名规则&#xff1a; lib 库的名字 .a 制作步骤 生成对应.o文件 .c .o 将生成的.o文件打包 ar rcs 静态库的名字&#xff08;libMytest.a&#xff09; 生成的所有的.o 发布和使用静态库&#xff1a; 1&#xff09; 发布静态 2&#xff09; 头文件 文件如下图所示&…

Linux之动态库

命令规则 lib 名字 .so 制作步骤 1&#xff09;生成与位置无关的代码&#xff08;生成与位置无关的代码&#xff09; 2&#xff09;将.o打包成共享库&#xff08;动态库&#xff09; 发布和使用共享库 动态库运行原理&#xff1a; 生成动态库&#xff1a; gcc -fPIC -c *.c -…

linux下源码安装vsftpd-3.0.2

1&#xff09;在http://vsftpd.beasts.org/网站中查找并下载 vsftpd-3.0.2.tar.gz源码包 2)如果自己的机器上安装有yum可以用yum grouplist | less指令查看以下开发环境&#xff0c;当然这一步不做也行 3&#xff09;拆解源码包 4&#xff09;查看源码包 5&#xff09;编辑…