中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

PHP中怎么實現多任務秒級定時器

發布時間:2021-08-07 11:37:30 來源:億速云 閱讀:134 作者:Leah 欄目:編程語言

PHP中怎么實現多任務秒級定時器,針對這個問題,這篇文章詳細介紹了相對應的分析和解答,希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。

實現

在實現定時器代碼的時候,用到了PHP系統自帶的兩個擴展

Pcntl - 多進程擴展 :

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

Spl - SplMinHeap - 小頂堆

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

流程

說明

1、定義定時器結構,有什么參數之類的.

2、然后全部注冊進我們的定時器類 Timer.

3、調用定時器類的monitor方法,開始進行監聽.

4、監聽過程就是一個while死循環,不斷的去看時間堆的堆頂是否到期了,本來考慮每秒循環看一次,后來一想每秒循環看一次還是有點問題,如果正好在我們sleep(1)的時候定時器有到期的了,那我們就不能馬上去精準執行,可能會有延時的風險,所以還是采用 usleep(1000) 毫秒級的去看并且也可以將進程掛起減輕 CPU 負載.

代碼

/***
* Class Timer
*/
class Timer extends SplMinHeap
{
  /**
  * 比較根節點和新插入節點大小
  * @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;
  }
  /**
  * 插入節點
  * @param mixed $value
  */
  public function insert($value)
  {
    $value['timeout'] = time() + $value['expire'];
    parent::insert($value);
  }
  /**
  * 監聽
  * @param bool $debug
  */
  public function monitor($debug = false)
  {
    while (!$this->isEmpty()) {
      $this->exec($debug);
      usleep(1000);
    }
  }
  /**
  * 執行
  * @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);
        }
        //忽略子進程,子進程退出由系統回收
        pcntl_signal(SIGCLD, SIG_IGN);
      } else {
        break;
      }
    }
    $t2 = microtime(true);
    echo ($debug && $hit) ? '時間堆 - 調整耗時: ' . round($t2 - $t1, 3) . "秒\r\n" : '';
  }
}

實例

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

執行結果

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

關于PHP中怎么實現多任務秒級定時器問題的解答就分享到這里了,希望以上內容可以對大家有一定的幫助,如果你還有很多疑惑沒有解開,可以關注億速云行業資訊頻道了解更多相關知識。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

php
AI

驻马店市| 桃源县| 咸宁市| 丰台区| 黑山县| 台南市| 黄平县| 安义县| 永和县| 泸定县| 虎林市| 盐亭县| 旬邑县| 工布江达县| 五峰| 连云港市| 广南县| 三江| 楚雄市| 抚顺县| 九台市| 日照市| 小金县| 富顺县| 蒙阴县| 肥西县| 南投县| 丰原市| 衡山县| 稷山县| 都匀市| 临洮县| 太湖县| 华池县| 泰顺县| 类乌齐县| 明光市| 固原市| 柳林县| 平顶山市| 梅河口市|