PHP多进程pcntl_fork、pcntl_wait那些事

PHP在多线程支持方面一直被人诟病，其实PHP可以支持多线程，不过需要单独安装扩展模块；
另外相比于多线程，其实多进程模块使用方面比多线程要更友好一些，如果你想在PHP中体验多进程OR多线程，那就跟随村长开始吧！

PHP多进程

一般涉及两个函数, pcntl_fork, pcntl_wait；

pcntl_fork

用于创建子进程，会在在当前进程当前位置产生分叉（所以取名fork）；

这个子进程仅 PID（进程号）和 PPID（父进程号）与其父进程不同；子进程的PID为0，PPID 为当前脚本执行时的进程号。
成功创建时，在父进程执行线程内返回产生的子进程的 PID，在子进程执行线程内返回 0。
失败时，在父进程上下文返回 -1，不会创建子进程，并且会引发 PHP 错误。

pcntl_wait

等待或返回 fork 的子进程状态, 注：该方法会阻塞当前进程的执行；

执行该函数时，会挂起当前进程的执行，直到一个子进程退出或接收到一个信号要求中断当前进程或调用一个信号处理函数；
如果一个子进程在调用此函数时已退出（俗称僵尸进程），此函数会立刻返回，子进程使用的所有系统资源将被释放；

执行顺序：

1.程序执行时，从外到内创建fork，再从内层最后一次fork开始依次退出；
2.如一次fork之后，其父进程因 pcntl_wait 阻塞，会等待之前已被执行的【任意fork子进程】退出后，再执行后面的逻辑；
3.执行本子进程的父进程依次循环步骤【2】的逻辑直到退出，最终结束总进程；

参考示例：

$maxLoop = 11; // 最大允许的folk次数，超过此数量后直接退出
$idxStart = 0; // folk次数-计数器
$maxcnt = 3; // 最大可允许的同时创建的进程数，可理解为 进程并发量；
$cnt = 0; // 已创建的进程 计数器；
while (1) { 
    $pid = pcntl_fork();
    if($pid===-1){
        die('folk err...');
    } else if($pid) {
        $idxStart++; // folk次数-计数器
        $cnt++;
        // 控制最大并发执行进程数，超过此数量，等待 任一子进程退出 后再执行；
        if($cnt >= $maxcnt){
            // pcntl_wait 里的 status 参数是引用传递，PHP 会存储状态信息到 status 参数上，通过 status 参数可监测当前进程是否正常执行完退出等等，这里不作详细解释，感兴趣的可直接参考PHP官网；
            pcntl_wait($status); // 防止僵尸子进程
            echo PHP_EOL, "Iam waiting: $cnt", PHP_EOL;
            print_r([$idxStart, $status]);
            echo PHP_EOL;
            if($idxStart>$maxLoop) {
                // 超过最大允许的folk次数，退出！
                echo PHP_EOL, "loop-num: {$idxStart}, stop...", PHP_EOL;
                exit(0);
            }
            $cnt--;
        }
    } else {
        sleep(1);
        echo PHP_EOL, "curr-i: $cnt", PHP_EOL;
        exit(0); // 避免子进程中执行foreach循环
        // 或者使用下面的方法，直接-kill
        posix_kill(getmypid(),9); // Instead of calling exit(), we use posix_kill()
    }
}

第二种调用方式

function mainExec()
{
    $count = 6;
    for ($i = 1; $i <= $count; $i++) {
        $pid = pcntl_fork();
        if ($pid > 0) {
            // 主进程相关操作...
        } else if (0 == $pid) {
            task($i);
            exit; // 一定要退出，否则子进程会继承上下文继续执行
        } else {
            echo "fork失败" . PHP_EOL;
        }
    }

    // sleep(10); // 放开此方法，会出现僵尸进程

    while ($count) {
        // 注意，pcntl_wait 是可以脱离循环主体独立执行的；
        $pid = pcntl_wait($result);
        var_dump($pid);
        var_dump($result);
        $count--;
    }
}

function task($taskId)
{
    // 此处，多进程执行相关逻辑。。。
    echo "task {$taskId} was done..", PHP_EOL;
}
mainExec();