您好,登錄后才能下訂單哦!
PHP中怎么實(shí)現(xiàn)多任務(wù)秒級(jí)定時(shí)器,針對(duì)這個(gè)問題,這篇文章詳細(xì)介紹了相對(duì)應(yīng)的分析和解答,希望可以幫助更多想解決這個(gè)問題的小伙伴找到更簡單易行的方法。
實(shí)現(xiàn)
在實(shí)現(xiàn)定時(shí)器代碼的時(shí)候,用到了PHP系統(tǒng)自帶的兩個(gè)擴(kuò)展
Pcntl - 多進(jìn)程擴(kuò)展 :
主要就是讓PHP可以同時(shí)開啟很多子進(jìn)程,并行的去處理一些任務(wù)。
Spl - SplMinHeap - 小頂堆
一個(gè)小頂堆數(shù)據(jù)結(jié)構(gòu),在實(shí)現(xiàn)定時(shí)器的時(shí)候,采用這種結(jié)構(gòu)效率還是不錯(cuò)的,插入、刪除的時(shí)間復(fù)雜度都是 O(logN) ,像 libevent 的定時(shí)器也在 1.4 版本以后采用了這種數(shù)據(jù)結(jié)構(gòu)之前用的是 rbtree,如果要是使用鏈表或者固定的數(shù)組,每次插入、刪除可能都需要重新遍歷或者排序,還是有一定的性能問題的。
流程
說明
1、定義定時(shí)器結(jié)構(gòu),有什么參數(shù)之類的.
2、然后全部注冊(cè)進(jìn)我們的定時(shí)器類 Timer.
3、調(diào)用定時(shí)器類的monitor方法,開始進(jìn)行監(jiān)聽.
4、監(jiān)聽過程就是一個(gè)while死循環(huán),不斷的去看時(shí)間堆的堆頂是否到期了,本來考慮每秒循環(huán)看一次,后來一想每秒循環(huán)看一次還是有點(diǎn)問題,如果正好在我們sleep(1)的時(shí)候定時(shí)器有到期的了,那我們就不能馬上去精準(zhǔn)執(zhí)行,可能會(huì)有延時(shí)的風(fēng)險(xiǎn),所以還是采用 usleep(1000) 毫秒級(jí)的去看并且也可以將進(jìn)程掛起減輕 CPU 負(fù)載.
代碼
/*** * Class Timer */ class Timer extends SplMinHeap { /** * 比較根節(jié)點(diǎn)和新插入節(jié)點(diǎn)大小 * @param mixed $value1 * @param mixed $value2 * @return int */ protected function compare($value1, $value2) { if ($value1['timeout'] > $value2['timeout']) { return -1; } if ($value1['timeout'] < $value2['timeout']) { return 1; } return 0; } /** * 插入節(jié)點(diǎn) * @param mixed $value */ public function insert($value) { $value['timeout'] = time() + $value['expire']; parent::insert($value); } /** * 監(jiān)聽 * @param bool $debug */ public function monitor($debug = false) { while (!$this->isEmpty()) { $this->exec($debug); usleep(1000); } } /** * 執(zhí)行 * @param $debug */ private function exec($debug) { $hit = 0; $t1 = microtime(true); while (!$this->isEmpty()) { $node = $this->top(); if ($node['timeout'] <= time()) { //出堆或入堆 $node['repeat'] ? $this->insert($this->extract()) : $this->extract(); $hit = 1; //開啟子進(jìn)程 if (pcntl_fork() == 0) { empty($node['action']) ? '' : call_user_func($node['action']); exit(0); } //忽略子進(jìn)程,子進(jìn)程退出由系統(tǒng)回收 pcntl_signal(SIGCLD, SIG_IGN); } else { break; } } $t2 = microtime(true); echo ($debug && $hit) ? '時(shí)間堆 - 調(diào)整耗時(shí): ' . round($t2 - $t1, 3) . "秒\r\n" : ''; } }
實(shí)例
$timer = new Timer(); //注冊(cè) - 3s - 重復(fù)觸發(fā) $timer->insert(array('expire' => 3, 'repeat' => true, 'action' => function(){ echo '3秒 - 重復(fù) - hello world' . "\r\n"; })); //注冊(cè) - 3s - 重復(fù)觸發(fā) $timer->insert(array('expire' => 3, 'repeat' => true, 'action' => function(){ echo '3秒 - 重復(fù) - gogo' . "\r\n"; })); //注冊(cè) - 6s - 觸發(fā)一次 $timer->insert(array('expire' => 6, 'repeat' => false, 'action' => function(){ echo '6秒 - 一次 - hello xxxx' . "\r\n"; })); //監(jiān)聽 $timer->monitor(false);
執(zhí)行結(jié)果
也測試過比較極端的情況,同時(shí)1000個(gè)定時(shí)器1s全部到期,時(shí)間堆全部調(diào)整完僅需 0.126s 這是沒問題的,但是每調(diào)整完一個(gè)定時(shí)器就需要去開啟一個(gè)子進(jìn)程,這塊可能比較耗時(shí)了,有可能1s處理不完這1000個(gè),就會(huì)影響下次監(jiān)聽繼續(xù)觸發(fā),但是不開啟子進(jìn)程,比如直接執(zhí)行應(yīng)該還是可以處理完的。。。。當(dāng)然肯定有更好的方法,目前只能想到這樣。
關(guān)于PHP中怎么實(shí)現(xiàn)多任務(wù)秒級(jí)定時(shí)器問題的解答就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,如果你還有很多疑惑沒有解開,可以關(guān)注億速云行業(yè)資訊頻道了解更多相關(guān)知識(shí)。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請(qǐng)聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。