PHP swoole的process模块创建和使用子进程操作示例(2)

<?php
$worker_process_nums = 5;
$worker_process = [];
 
for ($i = 0; $i < $worker_process_nums; $i++) {
  //注意，这里将参数$pipe_type设为false，表示不创建管道
  $worker = new swoole_process(function ($worker) {
    $task = json_decode($worker->pop(), true);
 
    $tmp = 0;
    for ($i = $task['start']; $i < $task['end']; $i++) {
      $tmp += $i;
    }
    echo "子进程 : {$worker->pid} 计算 {$task['start']} - {$task['end']} \n";
    $worker->push($tmp);
    $worker->exit();
  }, false, false);
 
  //使用消息队列，作为进程间的通信
  //注意，消息队列是共享的
  $worker->useQueue();
 
  $worker_process[$i] = $worker;
 
  //启动子进程
  $worker->start();
}
 
for ($i = 0; $i < $worker_process_nums; $i++) {
  //只需用一个子进程发送消息即可，因为消息队列是共享的
  $worker_process[0]->push(json_encode([
    'start' => mt_rand(1, 10),
    'end' => mt_rand(50, 100),
  ]));
}
 
//注意，这里要暂停，防止加入队列的任务，立刻被主进程读出来。
sleep(1);
 
for ($i = 0; $i < $worker_process_nums; $i++) {
  $result = $worker_process[0]->pop();
  echo "计算结果 : {$result} \n";
}
 
//父进程监听子进程退出信号，回收子进程，防止出现僵尸进程
swoole_process::signal(SIGCHLD, function ($sig) {
  //必须为false，非阻塞模式
  while ($ret = swoole_process::wait(false)) {
    echo "子进程 PID : {$ret['pid']} 退出\n";
  }
});

<?php
//每隔1秒触发SIGALAM信号
//注意，alarm不能和Timer同时使用
swoole_process::alarm(1000 * 1000, 0);
 
swoole_process::signal(SIGALRM, function ($signo) {
  static $cnt = 0;
  $cnt++;
  echo "时钟定时信号\n";
 
  if ($cnt > 10) {
    //清除定时器
    swoole_process::alarm(-1);
  }
});
 
swoole_process::signal(SIGINT, function ($signo) {
  echo "我被ctrl+c了\n";
 
  //退出主进程，不然将一直无法正常退出
  exit(0);
});