PHP 다중 작업 2차 타이머 구현 방법

이 글은 주로 PHP 다중 작업 2차 타이머의 구현 방법을 소개합니다. 매우 훌륭하고 참고할만한 가치가 있습니다. 필요한 친구들이 참고할 수 있습니다.

Description

최근 crontab을 배포할 때. 회사에서 갑자기 PHP를 사용하여 타이머를 구현할 수 있는지 궁금했습니다. crontab은 분 수준까지만 도달할 수 있기 때문에 세분성은 두 번째 수준이 될 것입니다. 동시에 PHP에 구현된 타이머가 많지 않다는 것도 조사했습니다. Swoole 확장에서는 밀리초 수준의 타이머를 구현하는 것이 매우 효율적이지만 결국 순수 PHP 코드로 작성되지 않았기 때문에 결국 PHP를 사용하여 학습 참조용 타이머 클래스를 구현하는 것을 고려했습니다.

구현

타이머 코드를 구현할 때 PHP 시스템과 함께 제공되는 두 가지 확장이 사용됩니다.

Pcntl - 다중 프로세스 확장:

주요 목적은 PHP가 여러 하위 프로세스를 시작하도록 허용하는 것입니다. 동시에 일부 작업을 동시에 처리합니다.

Spl - SplMinHeap - Small MinHeap

타이머를 구현할 때 이 구조를 사용하면 libevent와 마찬가지로 삽입 및 삭제의 시간 복잡도가 O(logN)인 타이머도 채택됩니다. 버전 1.4 이후에는 이 데이터 구조가 rbtree를 사용했습니다. 연결 목록이나 고정 배열을 사용하는 경우 각 삽입 또는 삭제를 다시 순회하거나 정렬해야 할 수 있으며 여전히 특정 성능 문제가 있습니다.

Process

Instructions

1. 타이머 구조와 어떤 매개변수가 있는지 정의합니다.
2. 그런 다음 타이머 클래스에 모두 등록합니다.
3. 모니터를 호출합니다.
4. 모니터링 프로세스는 무한 while 루프로, 시간 힙의 상단이 만료되었는지 지속적으로 확인합니다. 원래는 1초에 한 번씩 루프를 고려했지만 매초마다 생각했습니다. 한 번 반복하는 데에는 여전히 문제가 있습니다. sleep(1) 시 타이머가 만료되면 바로 정확하게 실행할 수 없고 지연될 위험이 있을 수 있으므로 여전히 usleep(1000) 밀리초를 사용합니다. 레벨 보기를 수행하고 프로세스를 일시 중지하여

Code

 /***
 * 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[&#39;timeout&#39;] < $value2[&#39;timeout&#39;]) {
       return 1;
     }
     return 0;
   }
   /**
   * 插入节点
   * @param mixed $value
   */
   public function insert($value)
   {
     $value[&#39;timeout&#39;] = time() + $value[&#39;expire&#39;];
     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[&#39;timeout&#39;] <= time()) {
         //出堆或入堆
         $node[&#39;repeat&#39;] ? $this->insert($this->extract()) : $this->extract();
         $hit = 1;
         //开启子进程
         if (pcntl_fork() == 0) {
           empty($node[&#39;action&#39;]) ? &#39;&#39; : call_user_func($node[&#39;action&#39;]);
           exit(0);
         }
         //忽略子进程,子进程退出由系统回收
         pcntl_signal(SIGCLD, SIG_IGN);
       } else {
         break;
       }
     }
     $t2 = microtime(true);
     echo ($debug && $hit) ? &#39;时间堆 - 调整耗时: &#39; . round($t2 - $t1, 3) . "秒\r\n" : &#39;&#39;;
   }
 }

Instance

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

Execution results

또한 테스트를 거쳤습니다. 극단적인 경우 1,000개의 타이머가 모두 동시에 1초에 만료되며 시간 힙을 조정하는 데 0.126초밖에 걸리지 않습니다. 이는 문제가 되지 않지만 타이머가 조정될 때마다 하위 프로세스를 시작해야 합니다. 더 복잡할 수 있습니다. 이러한 1,000개를 1초 안에 처리할 수 없으며 이는 다음 모니터링의 지속적인 트리거에 영향을 미칠 수 있습니다. 여전히 직접 실행으로 처리됩니다. . . . 물론 더 좋은 방법이 있을 텐데 현재로서는 이것밖에 생각이 나지 않습니다.

관련 권장 사항:

php 데이터베이스 캐시 구현 아이디어

위 내용은 PHP 다중 작업 2차 타이머 구현 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!