符合中小企业对网站设计、功能常规化式的企业展示型网站建设
本套餐主要针对企业品牌型网站、中高端设计、前端互动体验...
商城网站建设因基本功能的需求不同费用上面也有很大的差别...
手机微信网站开发、微信官网、微信商城网站...
PHP中怎么实现多任务秒级定时器,针对这个问题,这篇文章详细介绍了相对应的分析和解答,希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。
我们提供的服务有:网站设计制作、成都做网站、微信公众号开发、网站优化、网站认证、乾安ssl等。为成百上千家企事业单位解决了网站和推广的问题。提供周到的售前咨询和贴心的售后服务,是有科学管理、有技术的乾安网站制作公司
实现
在实现定时器代码的时候,用到了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中怎么实现多任务秒级定时器问题的解答就分享到这里了,希望以上内容可以对大家有一定的帮助,如果你还有很多疑惑没有解开,可以关注创新互联行业资讯频道了解更多相关知识。