[php]pthreadsのpoolについて

Question

困っていること

poolを利用しています。
以下phpコードですと、すべてのスレッドに最初に均等に割り振っている状態のようです。
1つのスレッドが長い処理を行うと、ほかのスレッド（ここでは全４つ）は作業が終わればプロセスが終了しているように見えております。（psで見ているぶんには）
そして、長い処理を行っているスレッドだけ独りでスタックされたjobを処理しているように見えております。

##知りたいこと
$p のうち1つ以上の作業が無い状態のスレッドが存在する確認方法がわかれば次の作業を渡したいです。（$p->submit(...));を）
この具体的なやり方をご教示いただければと思います。

##やっていること

# php5.3.29
# pthreads 2.0.10
class job extends Collectable
{
    public $val;

    public function __construct($arr)
    {
        $this->arr = $arr;
    }

    public function run()
    {
        usleep(250000);
        passthru('実行コマンド',$ret);
        $this->setGarbage();
    }
}
$p = new Pool(4);

$tasks = array();
$tasks[] = array(1,2,3);
$tasks[] = array(1,2,3);
$tasks[] = array(1,2,3);
$tasks[] = array(1,2,3);
for ($i = 0; $i < count($tasks); ++$i) {
    $p->submit(new job($tasks[$i]));
}

while($p->collect());
$p->shutdown();

Comments

[coco_bauer]

暇というのは、どんな状態の事ですか？

[退会済みユーザー]

ここでは4スレッドとしております。　そのうちの１つ以上のスレッドが作業が無い状態をさしております。

[退会済みユーザー]

暇という表記を訂正しました。暇→1つ以上の作業が無い状態

Answer 1

poolのcollectメソッドで、poolで稼働中のスレッドの数が判ります。

例えば、質問のコードの最後の行

while($p->collect());

は、稼働中のスレッドが無くなる(collectの結果が0(False)になる)まで待つというコードです。

稼働中のスレッドの数が、poolのサイズより小さければ、poolにスレッドを追加する（submitメソッドを使って、新しい仕事をするスレッドを作る）余裕がある訳ですから、残っている仕事があればスレッドを追加すると処理が早く終わります。

スレッドは生成されるとすぐに実行を始め、仕事が終われば消えます。
他のスレッドにjoinされるのを待っているというような状態は存在しますが、暇にしている(仕事が与えられるのを待っている）状態というのは普通ありません。