您好,登錄后才能下訂單哦!
$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)
{//子進(jìn)程要處理的邏輯
//echo "Worker: start. PID=".$worker->pid."\n";
//recv data from master
$recv = $worker->pop();//子進(jìn)程結(jié)束從主進(jìn)程傳過來的數(shù)據(jù)(2)
echo "From Master: $recv\n";
$worker->push(" \n hehe \n ");//這里子進(jìn)程向主進(jìn)程發(fā)送 hehe(3)
// sleep(2);//注意這里有個(gè)sleep
$worker->exit(0);
}
//向子進(jìn)程通信
foreach($workers as $pid => $process)
{
$process->push("hello worker[$pid]\n");//主進(jìn)程向子進(jìn)程發(fā)生數(shù)據(jù)(1)
sleep(3);
$result = $process->pop();//主進(jìn)程接收從子傳過來的數(shù)據(jù)(4)
echo "From worker: $result\n";//這里主進(jìn)程,接受到的子進(jìn)程的數(shù)據(jù)
}
for($i = 0; $i < $worker_num; $i++)
{
$ret = swoole_process::wait();//回收結(jié)束運(yùn)行的子進(jìn)程(5)
$pid = $ret['pid'];
unset($workers[$pid]);
echo "Worker Exit, PID=".$pid.PHP_EOL;
}
運(yùn)行結(jié)果:
例子1:
例子2:
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。