Process->push

投递数据到消息队列中。

  1. bool Process->push(string $data);
  • $data要投递的数据，长度受限与操作系统内核参数的限制。默认为8192，最大不超过65536
  • 操作失败会返回false，成功返回true
  • 默认模式下（阻塞模式），如果队列已满，push方法会阻塞等待
  • 非阻塞模式下，如果队列已满，push方法会立即返回false
    示例
  1. $workers = [];
  2. $worker_num = 2;
  4. for($i = 0; $i < $worker_num; $i++)
  5. {
  6.     $process = new swoole_process('callback_function', false, false);
  7.     $process->useQueue();
  8.     $pid = $process->start();
  9.     $workers[$pid] = $process;
  10.     //echo "Master: new worker, PID=".$pid."\n";
  11. }
  13. function callback_function(swoole_process $worker)
  14. {
  15.     //echo "Worker: start. PID=".$worker->pid."\n";
  16.     //recv data from master
  17.     $recv = $worker->pop();
  19.     echo "From Master: $recv\n";
  21.     sleep(2);
  22.     $worker->exit(0);
  23. }
  25. foreach($workers as $pid => $process)
  26. {
  27.     $process->push("hello worker[$pid]\n");
  28. }
  30. for($i = 0; $i < $worker_num; $i++)
  31. {
  32.     $ret = swoole_process::wait();
  33.     $pid = $ret['pid'];
  34.     unset($workers[$pid]);
  35.     echo "Worker Exit, PID=".$pid.PHP_EOL;
  36. }