libevent的使用方式是最開始調(diào)用event_init初始化一個(gè)全局的event_base指針,以后使用其中的API添加新的事件均是對(duì)這個(gè)指針進(jìn)行的操作.
試想如下一種典型的場(chǎng)景:主線程使用libevent處理網(wǎng)絡(luò)IO事件,接收新連接以及接收完客戶端的數(shù)據(jù)之后將該事件交給輔助線程進(jìn)行處理,輔助線程處理完了,需要往客戶端發(fā)送回應(yīng)數(shù)據(jù),則再通過libevent提供的API將這個(gè)事件添加到可讀事件中.但是,由于libevent中這個(gè)event_base指針是全局的,如果多線程同時(shí)添加可能會(huì)造成多線程不安全問題,這個(gè)在libevent的代碼注釋里面作者也做了注解.
在這個(gè)地方有人給出了解決的方案:
已經(jīng)有現(xiàn)成的解決方案：
http://monkeymail.org/archives/libevent-users/2006-October/000257.html
原作者給的地址好像已經(jīng)失效了。
iunknown在
spserver 中就是使用了他的代碼，可以從這里獲得
http://code.google.com/p/spserver/source/browse/trunk/spserver/event_msgqueue.h(對(duì)應(yīng)的C文件可以通過修改上面文件的后綴名所得).
簡(jiǎn)單的說一說這個(gè)event_msgqueue的原理及使用方式:
它的結(jié)構(gòu)體為:
struct event_msgqueue {
int push_fd;
int pop_fd;
int unlock_between_callbacks;
struct event queue_ev;
sp_thread_mutex_t lock;
void (*callback)(void *, void *);
void *cbarg;
struct circqueue *queue;
};
其中的queue是保存事件的隊(duì)列,callback是處理事件的回調(diào)函數(shù), lock是線程鎖.
首先,它創(chuàng)建了一對(duì)socketpair(也就是結(jié)構(gòu)體中的push_fd和pop_fd),將其中的一個(gè)通過libevent的event_add接口添加到關(guān)注的事件中,它的事件類型的是READ|PERSIST, 也就是說可讀同時(shí)永不刪除,而這個(gè)事件的回調(diào)函數(shù)是msgqueue_pop,這個(gè)函數(shù)的功能是將當(dāng)前queue中的數(shù)據(jù)一一取出并且調(diào)用callback函數(shù)進(jìn)行回調(diào)處理.
其次,外部的多線程需要往libevent添加事件時(shí)使用這個(gè)文件提供的msgqueue_push函數(shù)進(jìn)行添加,此時(shí), 往socketpair中發(fā)送一個(gè)字節(jié)的數(shù)據(jù), 這么做的目的是為了讓第一步已經(jīng)添加的socketpair得到響應(yīng),此時(shí), 由第一步,必然會(huì)觸發(fā)之前注冊(cè)的回調(diào)函數(shù)msgqueue_pop,將這個(gè)隊(duì)列中的事件取出來進(jìn)行處理.
這里使用socketpair起到了一個(gè)通知的作用,當(dāng)隊(duì)列中有數(shù)據(jù)時(shí),通過向socketpair發(fā)送數(shù)據(jù)以調(diào)用msgqueue_pop,將數(shù)據(jù)取出來進(jìn)行處理.
可見,這個(gè)event_msgqueue起了一個(gè)中間層的作用,輔助線程要往libevent添加事件就通過這個(gè)隊(duì)列,當(dāng)隊(duì)列中有數(shù)據(jù)時(shí)再觸發(fā)libevent的事件處理機(jī)制進(jìn)行處理.設(shè)計(jì)的非常巧妙.
感謝
iunknown兄的指點(diǎn):)