用PCNTL实现PHP多进程

PHP的进程控制支持实现了Unix方式的进程创建, 程序执行, 信号处理以及进程的中断。 进程控制不能被应用在Web服务器环境，当其被用于Web服务环境时可能会带来意外的结果。需要注意的是 PCNTL 是不支持在windows系统环境下使用的。

• PCNTL 多进程阻塞形式

<?php
$childProcessNum = 5;
for($i = 0; $i < $childProcessNum; ++$i) {
    $pids = pcntl_fork();
    if($pids == -1) {
        die('fork error');
    } else if ($pids) {
        pcntl_wait($status);
    } else {
        sleep(mt_rand(3,5));
        echo "{$i}\n";
        exit;
    }
}

在cli模式下执行，在终端可以看到会按顺序来输出每个执行的进程的序号

picture

• PCNTL 多进程非阻塞形式
  要使用非阻塞的多进程则只需要设置 pcntl_wait 的第二个参数为 WNOHANG 即可，即：

<?php
$childProcessNum = 5;
for($i = 0; $i < $childProcessNum; ++$i) {
    $pids = pcntl_fork();
    if($pids == -1) {
        die('fork error');
    } else if ($pids) {
        pcntl_wait($status, WNOHANG);
    } else {
        sleep(mt_rand(3,5));
        echo "{$i} - ";
        exit;
    }
}

pcntl_wait 在官方手册中是这样说明的：wait函数刮起当前进程的执行直到一个子进程退出或接收到一个信号要求中断当前进程或调用一个信号处理函数。 如果一个子进程在调用此函数时已经退出（俗称僵尸进程），此函数立刻返回。子进程使用的所有系统资源将被释放。

int pcntl_wait ( int &$status [, int $options = 0 ] )

pcntl_wait 这个函数有两个参数，第二个参数的说明如下：

image

在cli模式下执行修改后的代码，可以看到脚本已经执行完毕了，不过子进程由于sleep的原因还没执行完，过了几面才在终端输出执行结果。

此时用ps可以看到后台有5个进程正在执行：

image

执行结果：

image

• 配合 ticks 实现在同一时刻是控制进程数量

<?php
$maxProcess = 2;
$runningProcess = 0;
$arr = ['a', 'b', 'c', 'd', 'e', 'f', 'g'];

declare (ticks = 1);
pcntl_signal(SIGCHLD, function ($signo) {
    global $runningProcess;
    switch ($signo) {
        case SIGCHLD:
                $runningProcess--;
            break;
     }
});

for($i = 0; $i < 7; ++$i) {
    $runningProcess++;
    $pids = pcntl_fork();
    if($pids == -1) {
        die('fork error');
    } else if ($pids) {
        if ($runningProcess > $maxProcess) {
            pcntl_wait($status);
        }
    } else {
        sleep(mt_rand(3,4));
        echo "{$arr[$i]} \n";
        exit;
    }
}

• 同一时刻控制子进程数量

<?php
$max = 3;
$child = 0;
$arr = ['a', 'b', 'c', 'd', 'e', 'f', 'g'];

function sig_handler($signo) {
    switch ($signo) {
        case SIGCHLD:
        echo "SIGCHLD received\n";
        $child--;
    }
}

pcntl_signal(SIGCHLD, "sig_handler");

for ($i=0; $i < 7; $i++) { 
    $child++;
    $pid=pcntl_fork();
    
    if ($pid == -1) {
        die("could not fork");
    } else if ($pid) {
        if ( $child >= $max ) pcntl_wait($status);
    } else {
        echo "\t Starting new child | now we de have $child child processes $arr[$i]\n";
        sleep(rand(4,5));
        exit;
    }
}