之前的文章講過，我設(shè)計(jì)的網(wǎng)絡(luò)框架有幾組線程，分別是io、異步、同步、定時(shí)器，各個(gè)不同應(yīng)用server幾組線程組合形式不盡相同，簡單的可只有io線程，復(fù)雜一點(diǎn)的可io+同步，更復(fù)雜一點(diǎn)的也可io+同步+異步+定時(shí)器，總之我以幾組線程的自由組合方式應(yīng)付各種應(yīng)用，在我負(fù)責(zé)的server全是這一套框架實(shí)現(xiàn)的，不管是支持幾萬人連接的服務(wù)器，還是只有幾個(gè)用戶連接的內(nèi)部服務(wù)器，這套框架也算是久經(jīng)考驗(yàn)，穩(wěn)定運(yùn)行多年，內(nèi)部使用也非常簡單，如給sync線程組發(fā)一個(gè)消息只要PostSyncEvent，如果要給異步線程發(fā)一個(gè)消息只要發(fā)PostAsyncEvent，雖然只能開發(fā)的時(shí)候確定哪個(gè)任務(wù)在哪組線程執(zhí)行，但修改還是非常方便的，執(zhí)行體就是一組這樣的函數(shù)：
OnSyncEvent(DWORD dwEvent, DWORD wParam, DWORD lParam);
OnAsyncEvent(DWORD dwEvent, DWORD wParam, DWORD lParam);
一眼就知道是在哪個(gè)線程組里面執(zhí)行，當(dāng)然有的線程組是一個(gè)線程，有的線程組是多個(gè)，這涉及到有的資源是不是要加鎖，有經(jīng)驗(yàn)的開發(fā)人員很容易理解。
說了一下框架才容易理解我的問題，之前定時(shí)器是一個(gè)獨(dú)立的線程組，同步線程組、異步線程組、io組都沒有定時(shí)器功能，定時(shí)器觸發(fā)后要發(fā)送消息到相應(yīng)線程組，有的要發(fā)給異步線程組，有的要發(fā)給同步線程組，這就會引起線程切換，這是問題之一，還有一個(gè)問題，之前的定時(shí)器是由windows的時(shí)鐘隊(duì)列實(shí)現(xiàn)的，這個(gè)定時(shí)器優(yōu)點(diǎn)是很明顯的，定時(shí)精確，功能強(qiáng)大，參數(shù)眾多，獨(dú)立線程組，但也有很明顯的問題，如果要?jiǎng)h除一個(gè)定時(shí)器則有線程依賴，就是要在定時(shí)器線程才能刪除定時(shí)器，這個(gè)依賴約束很大，也很容易引起問題，用起來很不方便，使得一些資源的釋放不能夠即時(shí)進(jìn)行。正因?yàn)橛羞@么些問題，也為了使得時(shí)鐘模塊更容易移植，我設(shè)計(jì)了一個(gè)新時(shí)鐘模塊，為實(shí)現(xiàn)以下目標(biāo)：
1、無線程依賴，隨便調(diào)用者在哪個(gè)線程調(diào)用都可刪除指定的定時(shí)器。
2、和事件消息集成在一個(gè)線程內(nèi)，實(shí)現(xiàn)無需切換的定時(shí)器功能，這樣主線程、同步線程組、異步線程組都可在內(nèi)部處理定時(shí)器消息，無需單獨(dú)的定時(shí)器線程輔助，方便很多。
為實(shí)現(xiàn)以上目標(biāo)，我引入了libevent里面的minheap管理定時(shí)器，并根據(jù)之前管理事件的處理辦法，繼續(xù)使用iocp隊(duì)列管理線程消息，在每個(gè)線程組用iocp管理事件，根據(jù)最短觸發(fā)的定時(shí)器計(jì)算wait時(shí)間，這樣就在同一組線程內(nèi)實(shí)現(xiàn)了定時(shí)器和事件合并處理，當(dāng)然實(shí)現(xiàn)方法有很多，也可用iocp+WaitableTimer等，也可用apc，但那些實(shí)現(xiàn)的windows烙印都太深刻，雖然精度更高，實(shí)現(xiàn)更容易，我用minheap+iocp隊(duì)列方式的實(shí)現(xiàn)相對來說對windows的依賴較少，因?yàn)樘鎿Q一個(gè)iocp隊(duì)列處理事件是很容易的，這樣也方便移植和復(fù)用代碼。經(jīng)這樣修改之后，各個(gè)線程組包括主線程都可處理定時(shí)器和事件消息，也使得以前雞肋式的主線程終于可當(dāng)同步線程發(fā)揮作用，以前的定時(shí)器線程組也不一定需要了，既減少了線程，也減少了切換，現(xiàn)在各個(gè)線程組（包括主線程）都有完全一致的消息處理和時(shí)鐘處理函數(shù)。
事件函數(shù)：
OnTimerEvent(DWORD dwEvent, DWORD wParam, DWORD lParam);
OnSyncEvent(DWORD dwEvent, DWORD wParam, DWORD lParam);
OnAsyncEvent(DWORD dwEvent, DWORD wParam, DWORD lParam);
OnServiceEvent(DWORD dwEvent, DWORD wParam, DWORD lParam);
定時(shí)器函數(shù)：
OnTimerTimer(TlsInfo *ptls, EventTimer *et);
OnSyncTimer(TlsInfo *ptls, EventTimer *et);
OnAsyncTimer(TlsInfo *ptls, EventTimer *et);
OnIoTimer(TlsInfo *ptls, EventTimer *et);
OnServiceTimer(TlsInfo *ptls, EventTimer *et);
可以給線程組增加定時(shí)器刪除定時(shí)器
AddTimer、AddSyncTimer、AddAsyncTimer、AddServiceTimer、AddIoTimer
DelTimer、DelSyncTimer、DelAsyncTimer、DelServiceTimer、DelIoTimer
可給各線程組發(fā)消息
PostTimerEvent、PostSyncEvent、PostAsyncEvent、PostServiceEvent
這套框架是我多年服務(wù)器端開發(fā)的得意之作，體現(xiàn)了我簡潔實(shí)用的設(shè)計(jì)思想，用起來非常方便，可任意組合，適應(yīng)各種需求的應(yīng)用，由于除主線程之外的io線程組、同步線程組、異步線程組、定時(shí)器線程都是可以關(guān)、開1個(gè)、開多個(gè)，所以組合非常靈活，開1個(gè)可當(dāng)同步線程，開多個(gè)可當(dāng)異步線程（內(nèi)部搶資源），關(guān)閉就不存在該組線程，即使是io線程組也是可關(guān)的，這樣就使得這套框架不僅僅用在標(biāo)準(zhǔn)server上，就算是當(dāng)作一般的消息隊(duì)列服務(wù)器也沒問題，高度的靈活性使得這套框架可適應(yīng)各種規(guī)模的應(yīng)用，這次對定時(shí)器的改造使得這種組合更靈活，雖然現(xiàn)在的實(shí)現(xiàn)方法定時(shí)器的精度有一些下降，但瑕不掩瑜，這樣改造之后功能無疑是更強(qiáng)大了。