Live555通過(guò)一個(gè)while循環(huán)來(lái)不斷讀取socket，判斷是否有連接進(jìn)來(lái)，但是Live555并沒(méi)有使用Sleep函數(shù)來(lái)讓線程休眠多少毫秒來(lái)降低CPU占用率。Live555是通過(guò)select函數(shù)來(lái)實(shí)現(xiàn)Sleep，先計(jì)算出距離下次事件的時(shí)間，然后讓select超時(shí)為該時(shí)間值（tv_timeToDelay），如果有連接進(jìn)來(lái)則處理，沒(méi)有則等待直到超時(shí)。
int selectResult = select(fMaxNumSockets, &readSet, &writeSet, &exceptionSet, &tv_timeToDelay);

static BasicTaskScheduler* createNew(unsigned maxSchedulerGranularity = 10000/*microseconds*/);
創(chuàng)建BasicTaskScheduler對(duì)象的時(shí)候會(huì)將10毫秒作為默認(rèn)的事件時(shí)間間隔，創(chuàng)建定時(shí)任務(wù)。
DelayQueue是一個(gè)循環(huán)隊(duì)列，在BasicTaskScheduler::SingleStep() 結(jié)束前會(huì)調(diào)用該隊(duì)列的handleAlarm()函數(shù)，在handleAlarm()內(nèi)會(huì)首先釋放當(dāng)前Event，然后調(diào)用Event的handleTimeout()函數(shù)，由于在DelayQueue的派生類(lèi)AlarmHandler中已經(jīng)把handleTimeout()函數(shù)改寫(xiě)了，每次調(diào)用之前會(huì)先通過(guò)函數(shù)指針調(diào)用函數(shù)來(lái)創(chuàng)建一個(gè)新的AlarmHandle。然后再調(diào)用DelayQueueEntry::handleTimeout()。這樣保證每處理完一個(gè)Event，又會(huì)創(chuàng)建一個(gè)新的Event，確保工程能執(zhí)行下去，而且隊(duì)列里的節(jié)點(diǎn)又不會(huì)無(wú)限制增長(zhǎng)。

virtual void handleTimeout() {
? (*fProc)(fClientData);
? DelayQueueEntry::handleTimeout();
}

對(duì)于循環(huán)隊(duì)列DelayQueueEntry，如果要插入新的Event，將會(huì)匹配時(shí)間修改當(dāng)前Event，再把新Event插入的到當(dāng)前Event的前面，再修改前后指針，形成新的循環(huán)隊(duì)列。
void DelayQueue::addEntry(DelayQueueEntry* newEntry) {
? synchronize();

? DelayQueueEntry* cur = head();
? while (newEntry->fDeltaTimeRemaining >= cur->fDeltaTimeRemaining) {
??? newEntry->fDeltaTimeRemaining -= cur->fDeltaTimeRemaining;
??? cur = cur->fNext;
? }

? cur->fDeltaTimeRemaining -= newEntry->fDeltaTimeRemaining;

? // Add "newEntry" to the queue, just before "cur":
? newEntry->fNext = cur;
? newEntry->fPrev = cur->fPrev;
? cur->fPrev = newEntry->fPrev->fNext = newEntry;
}

計(jì)算延遲時(shí)間是在函數(shù)DelayQueue::synchronize()中進(jìn)行的，保存當(dāng)前時(shí)間，然后和上一次同步的時(shí)間做比較，判斷還有多少富余時(shí)間，再將富余時(shí)間返回。

以前開(kāi)發(fā)流媒體服務(wù)器，在進(jìn)行幀率處理時(shí)使用Sleep讓線程等待，但是Sleep誤差在40毫秒左右，導(dǎo)致聲音不流暢，后來(lái)還是改用其他函數(shù)進(jìn)行優(yōu)化。socket中的select()函數(shù)的誤差應(yīng)該會(huì)小些。

轉(zhuǎn)載于:https://www.cnblogs.com/ityujian/p/3139595.html

總結(jié)

以上是生活随笔為你收集整理的Live555研究之二Sleep实现的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

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