? ? ? ? 在《libev源碼解析——監(jiān)視器（watcher）結(jié)構(gòu)和組織形式》中介紹過，監(jiān)視器分為[2,-2]區(qū)間5個等級的優(yōu)先級。等級為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)視器鏈表無法滿足高等級優(yōu)先執(zhí)行的特性。那么libev是如何解決這個問題的呢？（轉(zhuǎn)載請指明出于breaksoftware的csdn博客）

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

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

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

?

#define NUMPRI (EV_MAXPRI - EV_MINPRI + 1)

? ? ? ? pendings是一個具有5（2-(-2)+1)）個元素的數(shù)組，不同等級和數(shù)組下標的對應(yīng)關(guān)系通過下面這個宏來換算

?

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

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

?

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

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

? ? ? ? pendings的每個元素是一個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是一個ev_watcher指針，它指向anfds中一個監(jiān)視器。我們看到這個結(jié)構(gòu)中沒有指向自身的指針，如next、pre之類，那就說明ANPENDING是用數(shù)組結(jié)構(gòu)保存的，而非動態(tài)鏈表。

?

? ? ? ??

? ? ? ? 那么anfds中的數(shù)據(jù)是如何轉(zhuǎn)移到pendings上的呢？這個工作是由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)視器中的等級轉(zhuǎn)換成pendings數(shù)組下標，從而確定該監(jiān)視器屬于哪個數(shù)組。

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

? ? ? ? 假如這個事件在一次循環(huán)中被觸發(fā)兩次。則第一次它會走入else的邏輯，根據(jù)pendingcnt中相應(yīng)等級找到其應(yīng)該屬于的pending位數(shù)。如果此時pandings空間不足，則需要使用array_needsize重新分配并填充該空間；第二次時，pending位已經(jīng)確定，此時只要更新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)用的。對于回調(diào)已經(jīng)被調(diào)用過的監(jiān)視器，libev不會將其從數(shù)組中去掉，而只是簡單的將其pending值設(shè)置為0。那么本次循環(huán)要遍歷的ANPENDING元素個數(shù)可能比數(shù)組個數(shù)要少，其個數(shù)是pendingcnt數(shù)組中相應(yīng)等級作為下標對應(yīng)的值。

? ? ? ? pendings中將數(shù)據(jù)準備好后，libev使用EV_INVOKE_PENDING宏遍歷本次循環(huán)中更新的ANPENDING對象，調(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源码解析——调度策略的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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