欧美精三区欧美精三区,精品乱子伦一区二区三区,欧美日韩精品一区

描述

最近在公司部署crontab的時候，突發奇想是否可以用PHP去實現一個定時器，顆粒度到秒級就好，因為crontab最多到分鐘級別，同時也調研了一下用PHP去實現的定時器還真不太多，Swoole 擴展里面到實現了一個毫秒級的定時器很高效，但畢竟不是純PHP代碼寫的，所以最后還是考慮用PHP去實現一個定時器類，以供學習參考。

實現

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

Pcntl - 多進程擴展 :

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

Spl - SplMinHeap - 小頂堆

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

流程

PHP 多任務秒級定時器的實現方法

說明

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

代碼

01/***
02* Class Timer
03*/
04class Timer extends SplMinHeap
05{
06  /**
07  * 比較根節點和新插入節點大小
08  * @param mixed $value1
09  * @param mixed $value2
10  * @return int
11  */
12  protected function compare($value1, $value2)
13  {
14    if ($value1['timeout'] > $value2['timeout']) {
15      return -1;
16    }
17    if ($value1['timeout'] < $value2['timeout']) {
18      return 1;
19    }
20    return 0;
21  }
22  /**
23  * 插入節點
24  * @param mixed $value
25  */
26  public function insert($value)
27  {
28    $value['timeout'] = time() + $value['expire'];
29    parent::insert($value);
30  }
31  /**
32  * 監聽
33  * @param bool $debug
34  */
35  public function monitor($debug = false)
36  {
37    while (!$this->isEmpty()) {
38      $this->exec($debug);
39      usleep(1000);
40    }
41  }
42  /**
43  * 執行
44  * @param $debug
45  */
46  private function exec($debug)
47  {
48    $hit = 0;
49    $t1  = microtime(true);
50    while (!$this->isEmpty()) {
51      $node = $this->top();
52      if ($node['timeout'] <= time()) {
53        //出堆或入堆
54        $node['repeat'] ? $this->insert($this->extract()) : $this->extract();
55        $hit = 1;
56        //開啟子進程
57        if (pcntl_fork() == 0) {
58          empty($node['action']) ? '' : call_user_func($node['action']);
59          exit(0);
60        }
61        //忽略子進程,子進程退出由系統回收
62        pcntl_signal(SIGCLD, SIG_IGN);
63      } else {
64        break;
65      }
66    }
67    $t2 = microtime(true);
68    echo ($debug && $hit) ? '時間堆 - 調整耗時: ' . round($t2 - $t1, 3) . "秒\r\n" : '';
69  }
70}

實例

01$timer = new Timer();
02//注冊 - 3s - 重復觸發
03$timer->insert(array('expire' => 3, 'repeat' => true, 'action' => function(){
04  echo '3秒 - 重復 - hello world' . "\r\n";
05}));
06//注冊 - 3s - 重復觸發
07$timer->insert(array('expire' => 3, 'repeat' => true, 'action' => function(){
08  echo '3秒 - 重復 - gogo' . "\r\n";
09}));
10//注冊 - 6s - 觸發一次
11$timer->insert(array('expire' => 6, 'repeat' => false, 'action' => function(){
12  echo '6秒 - 一次 - hello xxxx' . "\r\n";
13}));
14//監聽
15$timer->monitor(false);

執行結果

PHP 多任務秒級定時器的實現方法

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

總結

以上所述是小編給大家介紹的PHP 多任務秒級定時器的實現方法，希望對大家有所幫助，如果大家有任何疑問歡迎給我留言，小編會及時回復大家的！