$workers = [];
$worker_num = 2;

for($i = 0; $i < $worker_num; $i++)
{
    $process = new swoole_process(‘callback_function‘,false,false);
    $process->useQueue();
    $pid = $process->start();
    $workers[$pid] = $process;
    //echo "Master: new worker, PID=".$pid."\n";
}

function callback_function(swoole_process 
 
$worker)
{//子進程要處理的邏輯
    //echo "Worker: start. PID=".$worker->pid."\n";
    //recv data from master
    $recv = $worker->pop();//子進程結束從主進程傳過來的數據（2）
    echo "From Master: $recv\n";
    $worker->push(" \n   hehe   \n ");//這裏子進程向主進程發送  hehe（3）
//    sleep(2);//註意這裏有個sleep
    $worker->exit(0);

}

//向子進程通信
foreach($workers
 
 as $pid => $process)
{
    $process->push("hello worker[$pid]\n");//主進程向子進程發生數據（1）
    sleep(3);
    $result = $process->pop();//主進程接收從子傳過來的數據（4）
    echo "From worker: $result\n";//這裏主進程，接受到的子進程的數據
}

for($i = 0; $i < $worker_num; $i++)
{
    $ret = swoole_process::wait();//回收結束運行的子進程（5）
    $pid = $ret[‘pid‘
 
];
    unset($workers[$pid]);
    echo "Worker Exit, PID=".$pid.PHP_EOL;
}

運行結果：

例子1：

例子2：

本文出自 “我是程序我最大” 博客，請務必保留此出處http://skinglzw.blog.51cto.com/10729606/1964024

swoole process example