09.swoole学习笔记--进程事件

<?php
//进程数组
$workers=[];

//创建进程的数据量
$worker_num=3;

//创建启动进程
for($i=0;$i<$worker_num;$i++){
    //创建单独新进程
    $process=new swoole_process("doProcess");
    //启动进程并获取进程id
    $pid=$process->start();
    //存入进程数组
    $workers[$pid]=$process;
}

//创建进程对应的执行函数
function doProcess(swoole_process $process){
    //子进程写入信息
    $process->write("PID:$process->pid");
    echo "写入信息:$process->pid $process->callback";
}

//添加进程事件--向每一个子进程添加需要执行的动作
foreach($workers as $process){
    //添加进程事件--向每一个子进程添加需要执行的动作
    swoole_event_add($process->pipe,function($pipe) use($process){
        $data=$process->read();//能否读取数据
        echo "接收到:$data 
";
    });
}
?>