### 先简单测试一波运行速度
```php
<?php
$begin_time = microtime(true);

$worker_num = 2;
for($i=0; $i<$worker_num; $i++){
    $process = new swoole_process(function(swoole_process $worker) use($begin_time){
        for($i=0; $i<100000000; $i++){

}
        $spend_time = microtime(true) - $begin_time;
        echo "spend time {$spend_time}s".PHP_EOL;
    });
    $pid = $process->start();
    echo "pid = {$pid}".PHP_EOL;
}
```
结果：
```
pid = 16989
pid = 16990
spend time 1.1217679977417s
spend time 1.1285979747772s
```
###使用多进程创建三个子进程再试一波
```php
<?php
$begintime = microtime(true);

//子进程创建成功后要执行的函数
function handle(swoole_process $worker){
    sleep(1);//暂停1秒
    $cmd = $worker->read();
    //开启页面缓存
    ob_start();
    passthru($cmd);//执行外部程序并显示未经处理的原始输出
    $ret = ob_get_clean();
    //设置默认值
    $ret = empty($ret) ? "null" : $ret;
    $worker->write($ret);
}

//多进程
$cmds = ["uname", "date",  "whoami"];
foreach($cmds as $cmd){
    //创建子进程
    $process = new swoole_process("handle", true);
    $process->start();
    //通过管道发送数据到子进程
    $process->write($cmd);//管道是单向的发出的 数据必须由另一端读取。
    //同步阻塞读取管道数据
    echo $process->read();//获取命令执行结果
}
//子进程结束必须执行wait进行回收，否则子进程会变成僵尸进程。
while($ret = swoole_process::wait()){
    $pid = $ret["pid"];
    echo "worker exit: pid={$pid}".PHP_EOL;
}

$endtime = microtime(true);
echo sprintf("spend time %.3f s\n", $endtime-$begintime);
```
结果：
```
Linux
Mon Jan 13 15:32:38 CST 2020
root
worker exit: pid=17298
worker exit: pid=17301
worker exit: pid=17304
spend time 3.084 s
```
脚本执行耗费的时间是3秒多，为什么使用多进程开启3个子线程执行，还是3秒呢？

原因是父进程读取子进程返回的数据时是同步阻塞读取管道数据的
```php
echo $process->read();//获取命令执行结果
```
由于`read`是同步阻塞读取，导致父进程依次等待每个子进程处理完毕后才返回内容，进入下一个循环。

###解决方案1：先不获取子进程返回值，等循环结束后统一返回。
```php
<?php
$begintime = microtime(true);

//子进程创建成功后要执行的函数
function handle(swoole_process $worker){
    sleep(1);//暂停1秒
    $cmd = $worker->read();
    //开启页面缓存
    ob_start();
    passthru($cmd);//执行外部程序并显示未经处理的原始输出
    $ret = ob_get_clean();
    //设置默认值
    $ret = empty($ret) ? "null" : $ret;
    $worker->write($ret);
}

//多进程
$pros = [];
$cmds = ["uname", "date",  "whoami"];
foreach($cmds as $cmd){
    //创建子进程
    $process = new swoole_process("handle", true);
    $process->start();
    //通过管道发送数据到子进程
    $process->write($cmd);//管道是单向的发出的 数据必须由另一端读取。
    //先不获取子进程返回值等循环结束后统一返回
    $pros[] = $process;
}
//统一返回子进程数据
foreach($pros as $item){
    echo $item->read();
}
//子进程结束必须执行wait进行回收，否则子进程会变成僵尸进程。
while($ret = swoole_process::wait()){
    $pid = $ret["pid"];
    echo "worker exit: pid={$pid}".PHP_EOL;
}

$endtime = microtime(true);
echo sprintf("spend time %.3f s\n", $endtime-$begintime);
```
结果：
```
Linux
Mon Jan 13 15:35:16 CST 2020
root
worker exit: pid=17434
worker exit: pid=17433
worker exit: pid=17435
spend time 1.014 s
```
###解决方案2：使用swoole_event_add将管道加入到事件循环中，使其变为异步模式。
```php
<?php
$begintime = microtime(true);

//子进程创建成功后要执行的函数
function handle(swoole_process $worker){
    sleep(1);//暂停1秒
    $cmd = $worker->read();
    //开启页面缓存
    ob_start();
    passthru($cmd);//执行外部程序并显示未经处理的原始输出
    $ret = ob_get_clean();
    //设置默认值
    $ret = empty($ret) ? "null" : $ret;
    $worker->write($ret);
}

//多进程
$cmds = ["uname", "date",  "whoami"];
foreach($cmds as $cmd){
    //创建子进程
    $process = new swoole_process("handle", true);
    $process->start();
    //通过管道发送数据到子进程
    $process->write($cmd);//管道是单向的发出的 数据必须由另一端读取。
    //将管道加入到事件循环中使其转为异步模式
    swoole_event_add($process->pipe, function($pipe) use($process){
        echo $process->read();
    });
}
//子进程结束必须执行wait进行回收，否则子进程会变成僵尸进程。
while($ret = swoole_process::wait()){
    $pid = $ret["pid"];
    echo "worker exit: pid={$pid}".PHP_EOL;
}

$endtime = microtime(true);
echo sprintf("spend time %.3f s\n", $endtime-$begintime);
```
结果
```
worker exit: pid=17492
worker exit: pid=17493
worker exit: pid=17494
spend time 1.014 s
Mon Jan 13 15:36:21 CST 2020
Linux
root
```

已有0条评论

添加新评论☺

如果认为本文对您有所帮助请赞助本站

支付宝扫一扫赞助

已有0条评论

添加新评论☺