首页 >后端开发 >php教程 > 正文

PHP多任务秒级定时器的实现方法

转载2020-01-15 17:46:5501018
描述

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

实现

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

Pcntl - 多进程扩展 :

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

Spl - SplMinHeap - 小顶堆

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

流程

ee6901e9d45e395f3a4a47c8ba91cc0.png

说明

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);

执行结果

fc7b9bbe9fbd89a17f2087f6241d1c8.png

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

以上就是PHP多任务秒级定时器的实现方法的详细内容,更多请关注php中文网其它相关文章!

php中文网最新课程二维码
  • 相关标签:PHP
  • 本文转载于:csdn,如有侵犯,请联系a@php.cn删除
  • 相关文章

    相关视频


    网友评论

    文明上网理性发言,请遵守 新闻评论服务协议

    我要评论
  • 项目开发中,如果有要求,我们会使用linuxcrontab来解决,但是它最小粒度是分钟别,如果要求粒度是,甚至毫,crontab就无满足,值得庆幸是swoole提供强大
    下面由workerman教程栏目给大家介绍基于workerman库工具,希望对需要朋友有所帮助!
    本篇文章介绍了使用ThinkPHP,和cron,希望对学习thinkphp朋友有帮助!
    php间转:首先创建一个PHP示例文件;然后通过“$parsed['hour'] * 3600 $parsed['minute'] * 60 $parsed['second'];”将指间转换成数即可
    php:首先使用“ignore_user_abort()”函数,让浏览关掉也能使php脚本继续执行;然后通过“set_time_limit(0)”可以让程序无限制执行下去;最后写个循环来执行业逻辑
    php取消订单:首先【order_status】为1代表客户下单确;然后为2代表客户已付款;最后为0代表订单已取消,运用swoole异步毫
    下面由Laravel教程栏目给大家介绍PHP LaravelSchedule,希望对需要朋友有所帮助!
    下面几种都可以低于分钟粒度调度,各有优点,SystemD看起来更正规,但稍微复杂了一点,Crontab+sleep式虽然别扭,但对于一些小来说没有不能胜
    golang中设置:可以使用time包中Tick或Sleep。Sleep阻塞当前go协程至少d间段。Tick是NewTicker封装,只提供对Ticker通道访问。
    php聊天功能:1、在前端使用Ajax轮询访问php脚本,php再进行查询聊天数据进行返回给前端,最后前端将其进行渲染;2、使用WebSocket和服进行长连接,来聊天功能。
    下面由workerman使用教程栏目给大家介绍workerman异步,希望对需要朋友有所帮助!遇到一个问题,php是单线程,无线程。
    制作脚本mysql自动备份是:1、执行【vi dbbackup.sh】命令,编辑脚本文件;2、然后修改权限,并执行备份脚本;3、最后在打开文件输入即可。
    php手机位功能:首先创建“mobile.php”文件;然后获取手机浏览经纬度并post给服;接着创建“located.php”文件;最后通过百度位api进行解析位即可。
    MVC是一种将业逻辑、数据、界面显示分离,其控制作用是将业逻辑聚集到控制里面,从而在改进和个性化制界面及用户交互,不需要重新编写业逻辑。
    php页面跳转传递参数:可以通过使用服session来页面间参数传递。session是服储藏室,常被称作会话。
    下面由workerman教程栏目给大家介绍基于workerman推送,摒弃ajax轮询,希望对需要朋友有所帮助!
    php”防止表单重复提交是:使用“Token”(即令牌)来,当客户端请求页面,服生成一个随机数“Token”,并且将“Token”放置到“session”当中,然后将“Token”发给客户端
    一台服运行两个php版本是:1、首先运行安装你需要两个【php-fpm】;2、接着分别创建【php-fcgi】文件并保存;3、然后启用新【apache】配置;4、最后在其中一个版本上运行项目上创建文件并添加处理程序
    layui框架区别于那些基于MVVM底层UI框架,更是为服端程序员量身做,你无需涉足各种前端工具复杂配置,只需面对浏览本身。本教程为大家介绍了input输入和选择

    2020-08-05

    ​mysql中具有很扩张,mysql扩展、mydqli扩展、pdo_mysql扩展等.功能都是相同,pdo_mysql在高版本PHP中推荐使用。

    专题推荐

    推荐视频教程
  • javascript初级视频教程javascript初级视频教程
  • jquery 基础视频教程jquery 基础视频教程
  • 视频教程分类