libevent源码深度剖析七

时间:2021-10-01 00:03:51

libevent源码深度剖析七

——事件主循环
张亮

     现在我们已经初步了解了libevent的Reactor组件——event_base和事件管理框架,接下来就是libevent事件处理的中心部分——事件主循环,根据系统提供的事件多路分发机制执行事件循环,对已注册的就绪事件,调用注册事件的回调函数来处理事件。

1 阶段性的胜利

    Libevent将I/O事件、定时器和信号事件处理很好的结合到了一起,本节也会介绍libevent是如何做到这一点的。
    在看完本节的内容后,读者应该会对Libevent的基本框架:事件管理和主循环有比较清晰的认识了,并能够把libevent的事件控制流程清晰的串通起来,剩下的就是一些细节的内容了。

2 事件处理主循环

     Libevent的事件主循环主要是通过event_base_loop ()函数完成的,其主要操作如下面的流程图所示,event_base_loop所作的就是持续执行下面的循环。
 libevent源码深度剖析七 

清楚了event_base_loop所作的主要操作,就可以对比源代码看个究竟了,代码结构还是相当清晰的。

[cpp] view plain copy
  1. int event_base_loop(struct event_base *base, int flags)  
  2. {  
  3.     const struct eventop *evsel = base->evsel;  
  4.     void *evbase = base->evbase;  
  5.     struct timeval tv;  
  6.     struct timeval *tv_p;  
  7.     int res, done;  
  8.     // 清空时间缓存  
  9.     base->tv_cache.tv_sec = 0;  
  10.     // evsignal_base是全局变量,在处理signal时,用于指名signal所属的event_base实例  
  11.     if (base->sig.ev_signal_added)  
  12.         evsignal_base = base;  
  13.     done = 0;  
  14.     while (!done) { // 事件主循环  
  15.         // 查看是否需要跳出循环,程序可以调用event_loopexit_cb()设置event_gotterm标记  
  16.         // 调用event_base_loopbreak()设置event_break标记  
  17.         if (base->event_gotterm) {  
  18.             base->event_gotterm = 0;  
  19.             break;  
  20.         }  
  21.         if (base->event_break) {  
  22.             base->event_break = 0;  
  23.             break;  
  24.         }  
  25.         // 校正系统时间,如果系统使用的是非MONOTONIC时间,用户可能会向后调整了系统时间  
  26.         // 在timeout_correct函数里,比较last wait time和当前时间,如果当前时间< last wait time  
  27.         // 表明时间有问题,这是需要更新timer_heap中所有定时事件的超时时间。  
  28.         timeout_correct(base, &tv);  
  29.      
  30.         // 根据timer heap中事件的最小超时时间,计算系统I/O demultiplexer的最大等待时间  
  31.         tv_p = &tv;  
  32.         if (!base->event_count_active && !(flags & EVLOOP_NONBLOCK)) {  
  33.             timeout_next(base, &tv_p);  
  34.         } else {  
  35.             // 依然有未处理的就绪时间,就让I/O demultiplexer立即返回,不必等待  
  36.             // 下面会提到,在libevent中,低优先级的就绪事件可能不能立即被处理  
  37.             evutil_timerclear(&tv);  
  38.         }  
  39.         // 如果当前没有注册事件,就退出  
  40.         if (!event_haveevents(base)) {  
  41.             event_debug(("%s: no events registered.", __func__));  
  42.             return (1);  
  43.         }  
  44.         // 更新last wait time,并清空time cache  
  45.         gettime(base, &base->event_tv);  
  46.         base->tv_cache.tv_sec = 0;  
  47.         // 调用系统I/O demultiplexer等待就绪I/O events,可能是epoll_wait,或者select等;  
  48.         // 在evsel->dispatch()中,会把就绪signal event、I/O event插入到激活链表中  
  49.         res = evsel->dispatch(base, evbase, tv_p);  
  50.         if (res == -1)  
  51.             return (-1);  
  52.         // 将time cache赋值为当前系统时间  
  53.         gettime(base, &base->tv_cache);  
  54.         // 检查heap中的timer events,将就绪的timer event从heap上删除,并插入到激活链表中  
  55.         timeout_process(base);  
  56.         // 调用event_process_active()处理激活链表中的就绪event,调用其回调函数执行事件处理  
  57.         // 该函数会寻找最高优先级(priority值越小优先级越高)的激活事件链表,  
  58.         // 然后处理链表中的所有就绪事件;  
  59.         // 因此低优先级的就绪事件可能得不到及时处理;  
  60.         if (base->event_count_active) {  
  61.             event_process_active(base);  
  62.             if (!base->event_count_active && (flags & EVLOOP_ONCE))  
  63.                 done = 1;  
  64.         } else if (flags & EVLOOP_NONBLOCK)  
  65.             done = 1;  
  66.     }  
  67.     // 循环结束,清空时间缓存  
  68.     base->tv_cache.tv_sec = 0;  
  69.     event_debug(("%s: asked to terminate loop.", __func__));  
  70.     return (0);  
  71. }  

3 I/O和Timer事件的统一

     Libevent将Timer和Signal事件都统一到了系统的I/O 的demultiplex机制中了,相信读者从上面的流程和代码中也能窥出一斑了,下面就再啰嗦一次了。
     首先将Timer事件融合到系统I/O多路复用机制中,还是相当清晰的,因为系统的I/O机制像select()和epoll_wait()都允许程序制定一个最大等待时间(也称为最大超时时间)timeout,即使没有I/O事件发生,它们也保证能在timeout时间内返回。
那么根据所有Timer事件的最小超时时间来设置系统I/O的timeout时间;当系统I/O返回时,再激活所有就绪的Timer事件就可以了,这样就能将Timer事件完美的融合到系统的I/O机制中了。
     这是在Reactor和Proactor模式(主动器模式,比如Windows上的IOCP)中处理Timer事件的经典方法了,ACE采用的也是这种方法,大家可以参考POSA vol2书中的Reactor模式一节。
     堆是一种经典的数据结构,向堆中插入、删除元素时间复杂度都是O(lgN),N为堆中元素的个数,而获取最小key值(小根堆)的复杂度为O(1);因此变成了管理Timer事件的绝佳人选(当然是非唯一的),libevent就是采用的堆结构。

4 I/O和Signal事件的统一

     Signal是异步事件的经典事例,将Signal事件统一到系统的I/O多路复用中就不像Timer事件那么自然了,Signal事件的出现对于进程来讲是完全随机的,进程不能只是测试一个变量来判别是否发生了一个信号,而是必须告诉内核“在此信号发生时,请执行如下的操作”。
如果当Signal发生时,并不立即调用event的callback函数处理信号,而是设法通知系统的I/O机制,让其返回,然后再统一和I/O事件以及Timer一起处理,不就可以了嘛。是的,这也是libevent中使用的方法。
     问题的核心在于,当Signal发生时,如何通知系统的I/O多路复用机制,这里先买个小关子,放到信号处理一节再详细说明,我想读者肯定也能想出通知的方法,比如使用pipe。

5 小节

     介绍了libevent的事件主循环,描述了libevent是如何处理就绪的I/O事件、定时器和信号事件,以及如何将它们无缝的融合到一起。
加油!