libevent源码学习-----event

event_base是libevent的事件驱动，也是Reactor模式的直接体现。任何使用libevent的代码最开始都需要创建一个base，之后的任何接口函数都和这个base关联着，下面是struct event_base的定义


struct event_base {/* io多路复用函数的统一接口 */const struct eventop *evsel;/* io多路复用函数的数据 */void *evbase;/* 信号处理的统一接口 */const struct eventop *evsigsel;/* 信号处理的数据 */struct evsig_info sig;/* 注册到base中的event，不包括内部event */int event_count;/* 激活的event个数 */int event_count_active;/* 存储套接字/描述符以及对应的事件的map */struct event_io_map io;/* 存储信号的map */struct event_signal_map sigmap;/* 注册队列 */struct event_list eventqueue;/* 激活队列 */struct event_list *activequeues;/* 最小堆 */struct min_heap timeheap;/* ... */
};

struct event_base中主要包括上述变量，io多路复用操作，信号操作，各种map，队列，最小堆等等
其他的部分就是在程序设计过程中进行的各种判断，各种标志多一些
event_base的初始化是通过内部调用event_base_with_new_config实现的，函数意思是带有一些配置构造一个event_base，配置主要包括的就是用户不想要libevent使用的io复用函数名字。
函数中主要还是各种初始化，然后选择合适的io复用函数等

用户通过event_base_dispatch函数开启事件驱动的主循环，内部调用event_base_loop执行无线循环，也没有什么特别的

选择io复用函数的阻塞时长
调用io函数
判断最小堆中的event
处理所有激活的event

下面主要看一下如何处理激活event

/** 由base主循环调用，用来处理在base的激活队列中的event，* 根据优先级遍历base的激活队列数组，对于每一个队列，调用event_process_active_single_queue处理*/
static int
event_process_active(struct event_base *base)
{/* Caller must hold th_base_lock */struct event_list *activeq = NULL;int i, c = 0;for (i = 0; i < base->nactivequeues; ++i) {if (TAILQ_FIRST(&base->activequeues[i]) != NULL) {base->event_running_priority = i;activeq = &base->activequeues[i];c = event_process_active_single_queue(base, activeq);}}return c;
}

/** 处理激活/超时event的主要函数* 首先根据event是否是永久event判断是否需要将event从base的所有队列中删除* 如果是永久队列，则只需要从base的激活队列中删除* 然后才开始调用event的回调函数** 注意：此处需要处理具有超时时间的event，因为最小堆中记录的是绝对时间，* 所以如果这个event是具有超时时间的event，那么它是在从base中所有队列中删除后才加入到* 激活队列中的，见timeout_process()* 所以需要再将其添加到base中，重新调用event_add_internal即可,见event_persist_closure* * 返回处理了多少个非内部event*/
static int
event_process_active_single_queue(struct event_base *base,struct event_list *activeq)
{struct event *ev;int count = 0;for (ev = TAILQ_FIRST(activeq); ev; ev = TAILQ_FIRST(activeq)) {/* 如果是永久event，只需要从激活队列中删除 */if (ev->ev_events & EV_PERSIST)event_queue_remove(base, ev, EVLIST_ACTIVE);/* 否则就要从base的所有队列中删除，包括激活队列, 因为只处理一次 */elseevent_del_internal(ev);/* * 如果是信号或者永久event需要单独处理，而其他event在删除完之后直接调用回调函数就可以了* 以后就不再管这个event了,因为只处理一次* ev_closure用于判断是否是永久/信号event，在event_new中赋值*/switch (ev->ev_closure) {case EV_CLOSURE_SIGNAL:/* 信号的特殊处理，调用用户的信号处理函数 */event_signal_closure(base, ev);break;case EV_CLOSURE_PERSIST://io event/* 处理io事件，主要是特别处理有超时时间的event，需要重新计算绝对时间，然后调用回调函数 */event_persist_closure(base, ev);break;}}return count;
}

函数处理当前队列中的每一个event，首先将其从激活队列中删除，如果是一次性事件，则从base中删除
然后就根据信号/其他永久io事件调用相应的处理函数

总结
event_base是整个事件驱动的载体，但是使用时仅仅需要event_base_new，和event_base_dispatch即可，内部实现了对事件的监控，对超时event的统一处理，对所有激活event按优先级处理，处理时再细分是永久/一次性event，io/signal event等。这种先统一再分散的好处是可以在一个函数中统一处理激活event，实现更好的封装接口，也更容易理清思路。
对信号的处理需要特别注意，因为不是一有信号发生马上调用用户的回调函数，中间其实进行了两次base循环，这是为了将信号统一到event的结果，不然就直接sigaction绑定不是很好？
具有超时时间的event在处理时也是需要注意的部分，需要重新计算超时时间，然后使用event_add_internal重新添加（event在timeout_process已经被删除了），这就回到了event_add调用的event_add_internal上，如果不是超时event就仅仅是调用回调函数而已。
整体思路很容易理清，重点是细节方面，需要仔细琢磨

libevent源码学习-----event_base事件循环相关推荐

Libevent 源码学习笔记（1）event 与 event_base
目录 event event_base eventop evcb_closure event_callback event_changelist evsig_info event_io_map eve ...
libevent源码学习-----event操作
libevent核心结构是event_base和event,接下来主要介绍event结构 /* event的定义的主要部分 */ struct event {/* ... *//* event监听的描 ...
libevent源码学习-----阅读心得
框架设计思路 libevent使用统一事件源将所有问题都转化为event,比如将套接字/信号/描述符都在内部转化为event,由相应的io多路复用函数进行监控. 为了提供对超时event的支持,lib ...
libevent源码学习-----时间管理
libevent监听的event有以下几种文件描述符/套接字,没有设定超时时长信号文件描述符/套接字,设定超时时长对于时间,libevent内部的时间管理是通过最小堆实现的,原因如下既然某些 ...
libevent源码学习----io多路复用的封装和使用
因为是非阻塞监听事件的发生,所以内部其实还是采用io多路复用函数实现的. 又因为可供选择的io函数很多,linux下有epoll, poll, select等,window下有ICOP, select ...
libevent源码学习-----事件驱动流程分析
libevent中事件驱动的大体流程如下 /* 创建事件驱动 */ struct event_base* base = event_base_new(); /**创建一个事件*@param base: ...
Libevent源码学习笔记一：event2/event.h
一.libevent标准使用方法: 每个程序使用Libevent必须include <event2/event.h> 头文件,并传给 -levent 链接器.如果只是想使用主要的eve ...
libevent源码学习-----Reactor模型
libevent内部采用了reactor模型所谓reactor模型,其实就是一套事件注册机制,用来解决单线程的阻塞问题.reactor核心思想是将事件和相应事件发生时想要调用的函数都记录下来,在事件 ...
libevent源码学习-----统一事件源及信号绑定函数
libevent在对文件描述符,套接字进行监控时直接放到event,这些event通过io多路复用函数进行监控,然而对应信号来说io复用函数却无能为力,为了解决问题,libevent采用统一事件源的方 ...

libevent源码学习-----event_base事件循环

libevent源码学习-----event_base事件循环相关推荐

最新文章

热门文章