描述

創(chuàng)新互聯(lián)建站-專(zhuān)業(yè)網(wǎng)站定制、快速模板網(wǎng)站建設(shè)、高性?xún)r(jià)比裕華網(wǎng)站開(kāi)發(fā)、企業(yè)建站全套包干低至880元,成熟完善的模板庫(kù),直接使用。一站式裕華網(wǎng)站制作公司更省心,省錢(qián),快速模板網(wǎng)站建設(shè)找我們，業(yè)務(wù)覆蓋裕華地區(qū)。費(fèi)用合理售后完善，十年實(shí)體公司更值得信賴(lài)。

最近在公司部署crontab的時(shí)候，突發(fā)奇想是否可以用PHP去實(shí)現(xiàn)一個(gè)定時(shí)器，顆粒度到秒級(jí)就好，因?yàn)閏rontab最多到分鐘級(jí)別，同時(shí)也調(diào)研了一下用PHP去實(shí)現(xiàn)的定時(shí)器還真不太多，Swoole 擴(kuò)展里面到實(shí)現(xiàn)了一個(gè)毫秒級(jí)的定時(shí)器很高效，但畢竟不是純PHP代碼寫(xiě)的，所以最后還是考慮用PHP去實(shí)現(xiàn)一個(gè)定時(shí)器類(lèi)，以供學(xué)習(xí)參考。

實(shí)現(xiàn)

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

Pcntl - 多進(jìn)程擴(kuò)展 :

主要就是讓PHP可以同時(shí)開(kāi)啟很多子進(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ù)組，每次插入、刪除可能都需要重新遍歷或者排序，還是有一定的性能問(wèn)題的。

流程

說(shuō)明

1、定義定時(shí)器結(jié)構(gòu)，有什么參數(shù)之類(lèi)的.

2、然后全部注冊(cè)進(jìn)我們的定時(shí)器類(lèi) Timer.

3、調(diào)用定時(shí)器類(lèi)的monitor方法，開(kāi)始進(jìn)行監(jiān)聽(tīng).

4、監(jiān)聽(tīng)過(guò)程就是一個(gè)while死循環(huán)，不斷的去看時(shí)間堆的堆頂是否到期了，本來(lái)考慮每秒循環(huán)看一次，后來(lái)一想每秒循環(huán)看一次還是有點(diǎn)問(wè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)聽(tīng)
  * @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;
        //開(kāi)啟子進(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)聽(tīng)
$timer->monitor(false);

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

以上就是PHP多任務(wù)秒級(jí)定時(shí)器的實(shí)現(xiàn)方法的詳細(xì)內(nèi)容，更多請(qǐng)關(guān)注創(chuàng)新互聯(lián)其它相關(guān)文章！

當(dāng)前名稱(chēng)：PHP如何實(shí)現(xiàn)多任務(wù)秒級(jí)定時(shí)器
轉(zhuǎn)載來(lái)源：http://chinadenli.net/article40/jhhhho.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供自適應(yīng)網(wǎng)站、網(wǎng)站排名、面包屑導(dǎo)航、外貿(mào)網(wǎng)站建設(shè)、網(wǎng)站內(nèi)鏈、手機(jī)網(wǎng)站建設(shè)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶(hù)投稿、用戶(hù)轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話(huà)：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)