PHP 多任務(wù)秒級(jí)定時(shí)器的實(shí)現(xiàn)方法

<?php

/**** Class Timer*/
class Timer extends SplMinHeap
{
    /**
     * 比較根節(jié)點(diǎn)和新插入節(jié)點(diǎn)大小  
     * @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;
    }

    /**  
     * 插入節(jié)點(diǎn)  
     * @param mixed $value 
     */
    public function insert($value)
    {
        $value['timeout'] = time() + $value['expire'];
        parent::insert($value);
    }

    /**
     * 監(jiān)聽(tīng)  
     * @param bool $debug 
     */
    public function monitor($debug = false)
    {
        while (!$this->isEmpty()) {
            $this->exec($debug);
            usleep(1000);
        }
    }

    /**  
     * 執(zhí)行  
     * @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;        //開(kāi)啟子進(jìn)程
                if (pcntl_fork() == 0) {
                    empty($node['action']) ? '' : call_user_func($node['action']);
                    exit(0);
                }
                //忽略子進(jìn)程,子進(jìn)程退出由系統(tǒng)回收
                pcntl_signal(SIGCLD, SIG_IGN);
            } else {
                break;
            }
        }
        $t2 = microtime(true);
        echo ($debug && $hit) ? '時(shí)間堆 - 調(diào)整耗時(shí): ' . round($t2 - $t1, 3) . "秒\r\n" : '';
    }
}

<?php
$timer = new Timer();
//注冊(cè) - 3s - 重復(fù)觸發(fā)
$timer->insert(array('expire' => 3, 'repeat' => true, 'action' => function () {
    echo '3秒 - 重復(fù) - hello world' . "\r\n";
}));

//注冊(cè) - 3s - 重復(fù)觸發(fā)
$timer->insert(array('expire' => 3, 'repeat' => true, 'action' => function () {
    echo '3秒 - 重復(fù) - gogo' . "\r\n";
}));

//注冊(cè) - 6s - 觸發(fā)一次
$timer->insert(array('expire' => 6, 'repeat' => false, 'action' => function () {
    echo '6秒 - 一次 - hello xxxx' . "\r\n";
}));

//監(jiān)聽(tīng)
$timer->monitor(false)