? ? ? ? 在《libev源碼解析——監(jiān)視器（watcher）結(jié)構(gòu)和組織形式》中介紹過(guò)，監(jiān)視器分為[2,-2]區(qū)間5個(gè)等級(jí)的優(yōu)先級(jí)。等級(jí)為2的監(jiān)視器最高優(yōu)，然后依次遞減。不區(qū)分監(jiān)視器類型和關(guān)聯(lián)的文件描述符的值，權(quán)限高的要優(yōu)先于權(quán)限低的執(zhí)行。但是ANFD結(jié)構(gòu)中的監(jiān)視器鏈表無(wú)法滿足高等級(jí)優(yōu)先執(zhí)行的特性。那么libev是如何解決這個(gè)問(wèn)題的呢？（轉(zhuǎn)載請(qǐng)指明出于breaksoftware的csdn博客）

? ? ? ? anfds結(jié)構(gòu)是以文件描述符作為索引的，其關(guān)心的是該描述符對(duì)應(yīng)的事件是否發(fā)生。那我們關(guān)心不同等級(jí)執(zhí)行順序時(shí)，要以什么作為索引呢？那當(dāng)然是等級(jí)值。libev也的確是這么做的

VAR (pendings, ANPENDING *pendings [NUMPRI])
VAR (pendingmax, int pendingmax [NUMPRI])
VAR (pendingcnt, int pendingcnt [NUMPRI])

? ? ? ? NUMPRI是等級(jí)的個(gè)數(shù)，其定義是

?

#define NUMPRI (EV_MAXPRI - EV_MINPRI + 1)

? ? ? ? pendings是一個(gè)具有5（2-(-2)+1)）個(gè)元素的數(shù)組，不同等級(jí)和數(shù)組下標(biāo)的對(duì)應(yīng)關(guān)系通過(guò)下面這個(gè)宏來(lái)?yè)Q算

?

# define ABSPRI(w) (((W)w)->priority - EV_MINPRI)

? ? ? ? 可見(jiàn)高等級(jí)的位于數(shù)組末尾，低等級(jí)的位于數(shù)組頭部。即等級(jí)為2的pendings數(shù)組下標(biāo)是4，而等級(jí)為-2的下標(biāo)是0。

?

? ? ? ? pendingmax記錄的是每個(gè)等級(jí)已經(jīng)記錄的監(jiān)視器個(gè)數(shù)。

? ? ? ? pendingcnt記錄的是每個(gè)等級(jí)中當(dāng)前有效的監(jiān)視器個(gè)數(shù)。這個(gè)值和ev_watcher中pending值有很大的相關(guān)性，之后我們會(huì)去將討論。

? ? ? ? pendings的每個(gè)元素是一個(gè)ANPENDING指針，其定義如下

?

typedef ev_watcher *W;/* stores the pending event set for a given watcher */
typedef struct
{W w;int events; /* the pending event set for the given watcher */
} ANPENDING;

? ? ? ? 成員變量w是一個(gè)ev_watcher指針，它指向anfds中一個(gè)監(jiān)視器。我們看到這個(gè)結(jié)構(gòu)中沒(méi)有指向自身的指針，如next、pre之類，那就說(shuō)明ANPENDING是用數(shù)組結(jié)構(gòu)保存的，而非動(dòng)態(tài)鏈表。

?

? ? ? ??

? ? ? ? 那么anfds中的數(shù)據(jù)是如何轉(zhuǎn)移到pendings上的呢？這個(gè)工作是由ev_feed_event函數(shù)完成

?

void noinline
ev_feed_event (EV_P_ void *w, int revents) EV_THROW
{W w_ = (W)w;int pri = ABSPRI (w_);

? ? ? ? w是監(jiān)視器變量指針，revents是發(fā)生了的事件。ABSPRI宏將監(jiān)視器中的等級(jí)轉(zhuǎn)換成pendings數(shù)組下標(biāo)，從而確定該監(jiān)視器屬于哪個(gè)數(shù)組。

? ? ? ? 在一次循環(huán)前，每個(gè)監(jiān)視器的pending位都將是0。因?yàn)閷?duì)于沒(méi)有觸發(fā)的事件，其默認(rèn)是0；而對(duì)于本次觸發(fā)的事件，則在事件對(duì)應(yīng)的回調(diào)函數(shù)被執(zhí)行前，pending值被設(shè)置為0。該pending位的作用是用于記錄該監(jiān)視器信息在相應(yīng)等級(jí)pendings數(shù)組的子數(shù)組中的位置。

? ? ? ? 假如這個(gè)事件在一次循環(huán)中被觸發(fā)兩次。則第一次它會(huì)走入else的邏輯，根據(jù)pendingcnt中相應(yīng)等級(jí)找到其應(yīng)該屬于的pending位數(shù)。如果此時(shí)pandings空間不足，則需要使用array_needsize重新分配并填充該空間；第二次時(shí)，pending位已經(jīng)確定，此時(shí)只要更新events字段即可。

  if (expect_false (w_->pending))pendings [pri][w_->pending - 1].events |= revents;else{w_->pending = ++pendingcnt [pri];array_needsize (ANPENDING, pendings [pri], pendingmax [pri], w_->pending, EMPTY2);pendings [pri][w_->pending - 1].w      = w_;pendings [pri][w_->pending - 1].events = revents;}pendingpri = NUMPRI - 1;
}

?

? ? ? ? pendings里保存的是事件已經(jīng)被觸發(fā)的監(jiān)視器信息，這就包括回調(diào)已經(jīng)被調(diào)用的和即將被調(diào)用的。對(duì)于回調(diào)已經(jīng)被調(diào)用過(guò)的監(jiān)視器，libev不會(huì)將其從數(shù)組中去掉，而只是簡(jiǎn)單的將其pending值設(shè)置為0。那么本次循環(huán)要遍歷的ANPENDING元素個(gè)數(shù)可能比數(shù)組個(gè)數(shù)要少，其個(gè)數(shù)是pendingcnt數(shù)組中相應(yīng)等級(jí)作為下標(biāo)對(duì)應(yīng)的值。

? ? ? ? pendings中將數(shù)據(jù)準(zhǔn)備好后，libev使用EV_INVOKE_PENDING宏遍歷本次循環(huán)中更新的ANPENDING對(duì)象，調(diào)用其回調(diào)函數(shù)。

?

# define EV_INVOKE_PENDING ev_invoke_pending (EV_A)void noinline
ev_invoke_pending (EV_P)
{pendingpri = NUMPRI;while (pendingpri) /* pendingpri possibly gets modified in the inner loop */{--pendingpri;while (pendingcnt [pendingpri]){ANPENDING *p = pendings [pendingpri] + --pendingcnt [pendingpri];p->w->pending = 0;EV_CB_INVOKE (p->w, p->events);EV_FREQUENT_CHECK;}}
}#ifndef EV_CB_INVOKE
# define EV_CB_INVOKE(watcher,revents) (watcher)->cb (EV_A_ (watcher), (revents))
#endif

? ? ? ? 最后我們看下包括函數(shù)調(diào)用的結(jié)構(gòu)圖

?

總結(jié)

以上是生活随笔為你收集整理的libev源码解析——调度策略的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。