使用PHP怎么實現(xiàn)一個多任務(wù)秒級定時器

這期內(nèi)容當中小編將會給大家?guī)碛嘘P(guān)使用PHP怎么實現(xiàn)一個多任務(wù)秒級定時器，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

實現(xiàn)

在實現(xiàn)定時器代碼的時候，用到了PHP系統(tǒng)自帶的兩個擴展

Pcntl - 多進程擴展 :

主要就是讓PHP可以同時開啟很多子進程，并行的去處理一些任務(wù)。

Spl - SplMinHeap - 小頂堆

一個小頂堆數(shù)據(jù)結(jié)構(gòu)，在實現(xiàn)定時器的時候，采用這種結(jié)構(gòu)效率還是不錯的，插入、刪除的時間復(fù)雜度都是 O(logN) ，像 libevent 的定時器也在 1.4 版本以后采用了這種數(shù)據(jù)結(jié)構(gòu)之前用的是 rbtree，如果要是使用鏈表或者固定的數(shù)組，每次插入、刪除可能都需要重新遍歷或者排序，還是有一定的性能問題的。

流程

說明

1、定義定時器結(jié)構(gòu)，有什么參數(shù)之類的.
2、然后全部注冊進我們的定時器類 Timer.
 3、調(diào)用定時器類的monitor方法，開始進行監(jiān)聽.
4、監(jiān)聽過程就是一個while死循環(huán)，不斷的去看時間堆的堆頂是否到期了，本來考慮每秒循環(huán)看一次，后來一想每秒循環(huán)看一次還是有點問題，如果正好在我們sleep(1)的時候定時器有到期的了，那我們就不能馬上去精準執(zhí)行，可能會有延時的風險，所以還是采用 usleep(1000) 毫秒級的去看并且也可以將進程掛起減輕 CPU 負載.

代碼

 /***
 * Class Timer
 */
 class Timer extends SplMinHeap
 {
   /**
   * 比較根節(jié)點和新插入節(jié)點大小
   * @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é)點
   * @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;
         //開啟子進程
         if (pcntl_fork() == 0) {
           empty($node['action']) ? '' : call_user_func($node['action']);
           exit(0);
         }
         //忽略子進程,子進程退出由系統(tǒng)回收
         pcntl_signal(SIGCLD, SIG_IGN);
       } else {
         break;
       }
     }
     $t2 = microtime(true);
     echo ($debug && $hit) ? '時間堆 - 調(diào)整耗時: ' . round($t2 - $t1, 3) . "秒\r\n" : '';
   }
 }

實例

$timer = new Timer();
//注冊 - 3s - 重復(fù)觸發(fā)
$timer->insert(array('expire' => 3, 'repeat' => true, 'action' => function(){
  echo '3秒 - 重復(fù) - hello world' . "\r\n";
}));
//注冊 - 3s - 重復(fù)觸發(fā)
$timer->insert(array('expire' => 3, 'repeat' => true, 'action' => function(){
  echo '3秒 - 重復(fù) - gogo' . "\r\n";
}));
//注冊 - 6s - 觸發(fā)一次
$timer->insert(array('expire' => 6, 'repeat' => false, 'action' => function(){
  echo '6秒 - 一次 - hello xxxx' . "\r\n";
}));
//監(jiān)聽
$timer->monitor(false);

執(zhí)行結(jié)果

也測試過比較極端的情況，同時1000個定時器1s全部到期，時間堆全部調(diào)整完僅需 0.126s 這是沒問題的，但是每調(diào)整完一個定時器就需要去開啟一個子進程，這塊可能比較耗時了，有可能1s處理不完這1000個，就會影響下次監(jiān)聽繼續(xù)觸發(fā)，但是不開啟子進程，比如直接執(zhí)行應(yīng)該還是可以處理完的。。。。當然肯定有更好的方法，目前只能想到這樣。

php是什么語言

php，一個嵌套的縮寫名稱，是英文超級文本預(yù)處理語言（PHP:Hypertext Preprocessor）的縮寫。PHP 是一種 HTML 內(nèi)嵌式的語言，PHP與微軟的ASP頗有幾分相似，都是一種在服務(wù)器端執(zhí)行的嵌入HTML文檔的腳本語言，語言的風格有類似于C語言，現(xiàn)在被很多的網(wǎng)站編程人員廣泛的運用。

上述就是小編為大家分享的使用PHP怎么實現(xiàn)一個多任務(wù)秒級定時器了，如果剛好有類似的疑惑，不妨參照上述分析進行理解。如果想知道更多相關(guān)知識，歡迎關(guān)注億速云行業(yè)資訊頻道。