PCNTL関数を使用したプロセス制御でマルチプロセス(？)を実現するサンプル #PHP

PCNTL関数を使用したプロセス制御でマルチプロセス(？)を
実現するサンプルです。

参考にさせていただいたサイト(コード)

実装結果

processctrl.class.php

<?php
declare(ticks = 1);

class Processctrl {

    protected $_max_process = 3;

    protected $_timeout = 5;

    protected $_args;

    protected $_stack;

    static public function getInstace()
    {
        static $object;
        if (is_null($object)) {
            $object = new static;
        }

        return $object;
    }

    public function __construct()
    {
        $this->_args = array();
        $this->_stack = array();

        pcntl_signal(SIGALRM, function ($signal) {
            //Log::debug("Get signal [".$signal."]");
            switch ($signal) {
                case SIGALRM:
                    echo ">>>> TIMEOUT!! <<<<\n";
                    exit();
                    break;
                default:
                    break;
            }
        });
    }

    public static function setMaxProcess($max_process)
    {
        static::getInstace()->_max_process = $max_process;
    }

    public static function setTimeout($sec)
    {
        static::getInstace()->_timeout = $sec;
    }

    public function addArgs($args)
    {
        $this->_args[] = $args;
    }

    public function clearArgs()
    {
        $this->_args = array();
    }

    public function run_all(callable $callback)
    {
        if (!is_callable($callback)) {
            throw new \Exception('Not callable['.$callback.']');
        }

        // 子プロセスを生成し処理を実行する
        foreach ($this->_args as $args) {
            $pid = pcntl_fork();
            if (-1 === $pid) {
                throw new \Exception('False fork process ['.pcntl_get_last_error().']');
            }

            if ($pid) {
                //Log::debug("[" . __METHOD__ . "]: Parent process PID[".$pid."].");
                $this->_stack[$pid] = true;
                if (count($this->_stack) >= $this->_max_process) {
                    //Log::debug("[" . __METHOD__ . "]: Stacked process is max ...waiting...[".count($this->_stack)."].");
                    unset($this->_stack[pcntl_waitpid(-1, $status, WUNTRACED)]);
                }
            } else {
                //Log::debug("[" . __METHOD__ . "]: Child process running.");
                pcntl_alarm($this->_timeout);
                call_user_func_array($callback, $args);
                exit();
            }
        }

        // すべての子プロセスの終了を待つ
        while (count($this->_stack) > 0) {
            //Log::debug("[" . __METHOD__ . "]: Waiting process all end...[".count($this->_stack)."].");
            unset($this->_stack[pcntl_waitpid(-1, $status, WUNTRACED)]);
        }
    }
}

【補足】
declare(ticks = 1);
↑pcntl_signalを使用するために必要な記述。(ticksとか説明読んでもよくわかりません)
http://www.php.net/manual/ja/intro.pcntl.php
『…PCNTLはシグナルハンドルコールバックの仕組みとしてticksを使用しており…』

使用テスト（※PHP 5.4.11で実行しています）

尚、clearArgs()を忘れてaddArgs()とrun_all()を繰り返すと残念な事態になります。(なりました)

exec_multi_process_sample.php

<?php

require_once('./processctrl.class.php');

date_default_timezone_set('Asia/Tokyo');

$pctrl = Processctrl::getInstace();

// 【その１】
// 同時プロセス数は3に設定して
// 処理内容はsleep(2)を実行するだけ
$pctrl->setMaxProcess(3);

$pctrl->addArgs(array(1));
$pctrl->addArgs(array(2));
$pctrl->addArgs(array(3));
$pctrl->addArgs(array(4));
$pctrl->addArgs(array(5));
$pctrl->addArgs(array(6));
$pctrl->addArgs(array(7));
$pctrl->addArgs(array(8));

echo ">>> Run-1\n";
$pctrl->run_all(function($num) {
    $date = new DateTime("now");
    printf("$num SLEEP(02)[%s]\n", $date->format('Y-m-d H:i:s'));
    sleep(2);
    $date = new DateTime("now");
    printf("$num END[%s]\n", $date->format('Y-m-d H:i:s'));
});

// 【その２】
// 同時プロセス数は5に設定して、タイムアウト時間を6に設定
// 処理内容はsleep(5)を実行するだけ(∴タイムアウトしない)
// ※clearArgs()していないので「その１」で設定した引数で実行される

$pctrl = Processctrl::getInstace();
$pctrl->setMaxProcess(5);
$pctrl->setTimeout(6);

echo ">>> Run-2\n";
$pctrl->run_all(function($num) {
    $date = new DateTime("now");
    printf("$num SLEEP(05)[%s]\n", $date->format('Y-m-d H:i:s'));
    sleep(5);
    $date = new DateTime("now");
    printf("$num END[%s]\n", $date->format('Y-m-d H:i:s'));
});

// 【その２】
// 同時プロセス数は2に設定して、タイムアウト時間を5に設定
// 処理内容はsleep(10)を実行するだけ(∴タイムアウトする)
// ※clearArgs()して新たに引数をセット

$pctrl->clearArgs();
$pctrl->setMaxProcess(2);
$pctrl->setTimeout(5);

$pctrl->addArgs(array(1));
$pctrl->addArgs(array(2));
$pctrl->addArgs(array(3));
$pctrl->addArgs(array(4));

echo ">>> Run-3\n";
$pctrl->run_all(function($num) {
    $date = new DateTime("now");
    printf("$num SLEEP(10)[%s]\n", $date->format('Y-m-d H:i:s'));
    sleep(10);
    $date = new DateTime("now");
    printf("$num END[%s]\n", $date->format('Y-m-d H:i:s'));
});

実行結果

>>> Run-1
1 SLEEP(02)[2013-05-06 17:37:21]
2 SLEEP(02)[2013-05-06 17:37:21]
3 SLEEP(02)[2013-05-06 17:37:21]
1 END[2013-05-06 17:37:23]
2 END[2013-05-06 17:37:23]
3 END[2013-05-06 17:37:23]
4 SLEEP(02)[2013-05-06 17:37:23]
5 SLEEP(02)[2013-05-06 17:37:23]
6 SLEEP(02)[2013-05-06 17:37:23]
4 END[2013-05-06 17:37:25]
5 END[2013-05-06 17:37:25]
6 END[2013-05-06 17:37:25]
7 SLEEP(02)[2013-05-06 17:37:25]
8 SLEEP(02)[2013-05-06 17:37:25]
7 END[2013-05-06 17:37:27]
8 END[2013-05-06 17:37:27]

>>> Run-2
1 SLEEP(05)[2013-05-06 17:37:27]
2 SLEEP(05)[2013-05-06 17:37:27]
3 SLEEP(05)[2013-05-06 17:37:27]
4 SLEEP(05)[2013-05-06 17:37:27]
5 SLEEP(05)[2013-05-06 17:37:27]
1 END[2013-05-06 17:37:32]
2 END[2013-05-06 17:37:32]
3 END[2013-05-06 17:37:32]
4 END[2013-05-06 17:37:32]
5 END[2013-05-06 17:37:32]
6 SLEEP(05)[2013-05-06 17:37:32]
7 SLEEP(05)[2013-05-06 17:37:32]
8 SLEEP(05)[2013-05-06 17:37:32]
6 END[2013-05-06 17:37:37]
7 END[2013-05-06 17:37:37]
8 END[2013-05-06 17:37:37]

>>> Run-3
1 SLEEP(10)[2013-05-06 17:37:37]
2 SLEEP(10)[2013-05-06 17:37:37]
1 END[2013-05-06 17:37:42]
>>>> TIMEOUT!! <<<<
2 END[2013-05-06 17:37:42]
>>>> TIMEOUT!! <<<<
3 SLEEP(10)[2013-05-06 17:37:42]
4 SLEEP(10)[2013-05-06 17:37:42]
3 END[2013-05-06 17:37:47]
>>>> TIMEOUT!! <<<<
4 END[2013-05-06 17:37:47]
>>>> TIMEOUT!! <<<<