php使用多进程（pcntl）

Posted 2020-11-18

<?php
/**
 * this is a demo for php fork and pipe usage. fork use
 * to create child process and pipe is used to sychoroize
 * the child process and its main process.
 * @author bourneli
 * @date: 2012-7-6
 */
define("PC", 10); // 进程个数
define("TO", 4); // 超时
if (!function_exists(‘pcntl_fork‘)) {
    die("pcntl_fork not existing");
}
// 创建管道
$sPipePath = "my_pipe.".posix_getpid();
if (!posix_mkfifo($sPipePath, 0666)) {
    die("create pipe {$sPipePath} error");
}
// 模拟任务并发
for ($i = 0; $i < PC; ++$i ) {
    $nPID = pcntl_fork(); // 创建子进程
    if ($nPID == 0) {
        // 子进程过程
        for($j=0;$j<99999;$j++){
            touch("test/{$i}{$j}.txt");
        }
        $oW = fopen($sPipePath, ‘w‘);
        fwrite($oW, $i."
"); // 当前任务处理完比，在管道中写入数据
        fclose($oW);
        exit(0); // 执行完后退出
    }
}
// 父进程
$oR = fopen($sPipePath, ‘r‘);
stream_set_blocking($oR, FALSE); // 将管道设置为非堵塞，用于适应超时机制
$sData = ‘‘; // 存放管道中的数据
$nLine = 0;
$nStart = time();
while ($nLine < PC && (time() - $nStart) < TO) {
    $sLine = fread($oR, 1024);
    if (empty($sLine)) {
        continue;   
    }
    echo "current line: {$sLine}
";
    // 用于分析多少任务处理完毕，通过‘
’标识
    foreach(str_split($sLine) as $c) {
        if ("
" == $c) {
            ++$nLine;
        }
    }
    $sData .= $sLine;
}
echo "Final line count:$nLine
";
fclose($oR);
unlink($sPipePath); // 删除管道，已经没有作用了
// 等待子进程执行完毕，避免僵尸进程
$n = 0;
while ($n < PC) {
    $nStatus = -1;
    $nPID = pcntl_wait($nStatus, WNOHANG);
    if ($nPID > 0) {
        echo "{$nPID} exit
";
        ++$n;
    }
}
// 验证结果，主要查看结果中是否每个任务都完成了
$arr2 = array();
foreach(explode("
", $sData) as $i) {// trim all
    if (is_numeric(trim($i))) {
        array_push($arr2, $i);  
    }
}
$arr2 = array_unique($arr2);
if ( count($arr2) == PC) {  
    echo ‘ok‘; 
} else {
    echo  "error count " . count($arr2) . "
";
    var_dump($arr2);
}