日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當(dāng)前位置: 首頁(yè) > 编程资源 > 编程问答 >内容正文

编程问答

Live555研究之二Sleep实现

發(fā)布時(shí)間:2024/4/17 编程问答 38 豆豆
生活随笔 收集整理的這篇文章主要介紹了 Live555研究之二Sleep实现 小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.

Live555通過一個(gè)while循環(huán)來不斷讀取socket,判斷是否有連接進(jìn)來,但是Live555并沒有使用Sleep函數(shù)來讓線程休眠多少毫秒來降低CPU占用率。Live555是通過select函數(shù)來實(shí)現(xiàn)Sleep,先計(jì)算出距離下次事件的時(shí)間,然后讓select超時(shí)為該時(shí)間值(tv_timeToDelay),如果有連接進(jìn)來則處理,沒有則等待直到超時(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的派生類AlarmHandler中已經(jīng)把handleTimeout()函數(shù)改寫了,每次調(diào)用之前會(huì)先通過函數(shù)指針調(diào)用函數(shù)來創(chuàng)建一個(gè)新的AlarmHandle。然后再調(diào)用DelayQueueEntry::handleTimeout()。這樣保證每處理完一個(gè)Event,又會(huì)創(chuàng)建一個(gè)新的Event,確保工程能執(zhí)行下去,而且隊(duì)列里的節(jié)點(diǎn)又不會(huì)無限制增長(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í)間返回。

以前開發(fā)流媒體服務(wù)器,在進(jìn)行幀率處理時(shí)使用Sleep讓線程等待,但是Sleep誤差在40毫秒左右,導(dǎo)致聲音不流暢,后來還是改用其他函數(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ǎng)站內(nèi)容還不錯(cuò),歡迎將生活随笔推薦給好友。