最近在公司部署crontab的时候，突发奇想是否可以用PHP去实现一个定时器，颗粒度到秒级就好，因为crontab最多到分钟级别，同时也调研了一下用PHP去实现的定时器还真不太多，Swoole 扩展里面到实现了一个毫秒级的定时器很高效，但毕竟不是纯PHP代码写的，所以最后还是考虑用PHP去实现一个定时器类，以供学习参考。

实现

在实现定时器代码的时候，用到了PHP系统自带的两个扩展

Pcntl - 多进程扩展 :

主要就是让PHP可以同时开启很多子进程，并行的去处理一些任务。

Spl - SplMinHeap - 小顶堆

一个小顶堆数据结构，在实现定时器的时候，采用这种结构效率还是不错的，插入、删除的时间复杂度都是 O(logN) ，像 libevent 的定时器也在 1.4 版本以后采用了这种数据结构之前用的是 rbtree，如果要是使用链表或者固定的数组，每次插入、删除可能都需要重新遍历或者排序，还是有一定的性能问题的。

流程

说明

1、定义定时器结构，有什么参数之类的.

2、然后全部注册进我们的定时器类 Timer.

3、调用定时器类的monitor方法，开始进行监听.

4、监听过程就是一个while死循环，不断的去看时间堆的堆顶是否到期了，本来考虑每秒循环看一次，后来一想每秒循环看一次还是有点问题，如果正好在我们sleep(1)的时候定时器有到期的了，那我们就不能马上去精准执行，可能会有延时的风险，所以还是采用 usleep(1000) 毫秒级的去看并且也可以将进程挂起减轻 CPU 负载.

代码：

1. /*** 
2.  
3. * Class Timer 
4.  
5. */ 
6.  
7. class Timer extends SplMinHeap 
8.  
9. { 
10.  
11.   /** 
12.  
13.   * 比较根节点和新插入节点大小 
14.  
15.   * @param mixed $value1 
16.  
17.   * @param mixed $value2 
18.  
19.   * @return int 
20.  
21.   */ 
22.  
23.   protected function compare($value1, $value2) 
24.  
25.   { 
26.  
27.     if ($value1['timeout'] > $value2['timeout']) { 
28.  
29.       return -1; 
30.  
31.     } 
32.  
33.     if ($value1['timeout'] < $value2['timeout']) { 
34.  
35.       return 1; 
36.  
37.     } 
38.  
39.     return 0; 
40.  
41.   } 
42.  
43.   /** 
44.  
45.   * 插入节点 
46.  
47.   * @param mixed $value 
48.  
49.   */ 
50.  
51.   public function insert($value) 
52.  
53.   { 
54.  
55.     $value['timeout'] = time() + $value['expire']; 
56.  
57.     parent::insert($value); 
58.  
59.   } 
60.  
61.   /** 
62.  
63.   * 监听 
64.  
65.   * @param bool $debug 
66.  
67.   */ 
68.  
69.   public function monitor($debug = false) 
70.  
71.   { 
72.  
73.     while (!$this->isEmpty()) { 
74.  
75.       $this->exec($debug); 
76.  
77.       usleep(1000); 
78.  
79.     } 
80.  
81.   } 
82.  
83.   /** 
84.  
85.   * 执行 
86.  
87.   * @param $debug 
88.  
89.   */ 
90.  
91.   private function exec($debug) 
92.  
93.   { 
94.  
95.     $hit = 0; 
96.  
97.     $t1  = microtime(true); 
98.  
99.     while (!$this->isEmpty()) { 
100.  
101.       $node = $this->top(); 
102.  
103.       if ($node['timeout'] <= time()) { 
104.  
105.         //出堆或入堆 
106.  
107.         $node['repeat'] ? $this->insert($this->extract()) : $this->extract(); 
108.  
109.         $hit = 1; 
110.  
111.         //开启子进程 
112.  
113.         if (pcntl_fork() == 0) { 
114.  
115.           emptyempty($node['action']) ? '' : call_user_func($node['action']); 
116.  
117.           exit(0); 
118.  
119.         } 
120.  
121.         //忽略子进程,子进程退出由系统回收 
122.  
123.         pcntl_signal(SIGCLD, SIG_IGN); 
124.  
125.       } else { 
126.  
127.         break; 
128.  
129.       } 
130.  
131.     } 
132.  
133.     $t2 = microtime(true); 
134.  
135.     echo ($debug && $hit) ? '时间堆 - 调整耗时: ' . round($t2 - $t1, 3) . "秒\r\n" : ''; 
136.  
137.   } 
138.  
139. } 

实例：

1. $timer = new Timer(); 
2.  
3. //注册 - 3s - 重复触发 
4.  
5. $timer->insert(array('expire' => 3, 'repeat' => true, 'action' => function(){ 
6.  
7.   echo '3秒 - 重复 - hello world' . "\r\n"; 
8.  
9. })); 
10.  
11. //注册 - 3s - 重复触发 
12.  
13. $timer->insert(array('expire' => 3, 'repeat' => true, 'action' => function(){ 
14.  
15.   echo '3秒 - 重复 - gogo' . "\r\n"; 
16.  
17. })); 
18.  
19. //注册 - 6s - 触发一次 
20.  
21. $timer->insert(array('expire' => 6, 'repeat' => false, 'action' => function(){ 
22.  
23.   echo '6秒 - 一次 - hello xxxx' . "\r\n"; 
24.  
25. })); 
26.  
27. //监听 
28.  
29. $timer->monitor(false); 

执行结果：

也测试过比较极端的情况，同时1000个定时器1s全部到期，时间堆全部调整完仅需 0.126s 这是没问题的，但是每调整完一个定时器就需要去开启一个子进程，这块可能比较耗时了，有可能1s处理不完这1000个，就会影响下次监听继续触发，但是不开启子进程，比如直接执行应该还是可以处理完的。。。。当然肯定有更好的方法，目前只能想到这样。

Tags: PHP多任务秒级定时器

分享到：