HattaraTecLog

今日は、perlのParallel::Prefork(Parallel/Prefork.pm)で出たエラーについてメモ。
結論からいうと、今回のパターンは、Parallel::Preforkのバージョンと組み方の問題でした。
(※あくまでエラーメッセージの条件説明じゃなく、こんなパターンで出る場合があるよという感じで見てください)

では、簡単なテストスクリプトを書いてみます。

#!/usr/local/bin/env perl
use strict;
use warnings;
use FindBin;
use lib "$FindBin::Bin/Parallel-Prefork-0.08/lib/";
use Parallel::Prefork;

my $pm = Parallel::Prefork->new({
        max_workers => 2,
        trap_signals => {
            TERM => 'TERM',
        },
    });

while ($pm->signal_received ne 'TERM') {
    $pm->start(sub {
        sleep(3);
        warn "end:" . time();
    });
}
$pm->wait_all_children();

これを実行すると、

cannot start another process while you are in child process at ...../Parallel/Prefork.pm line 42.

みたいなエラーが表示されます。

これは、手元にあった0.10未満のバージョンのParallel::Preforkを利用して、
0.10から実装された「- support new style: $pm->start(sub { … })」の形で
コードを実装してしまっている為です。

【0.10未満のParallel::Prefork】
$pm->start(sub{})に対応していないので、上記のコードだと、
何も処理されずにstartだけしてwhile分がまわります。
ここで問題なのは、Parallel::Prefoxkを正常終了するには、$pm->finishしないといけないという事。
この場合、$pm->start(sub{});で渡した内容が宙に浮きます。そして、finishが走る要素がなくなります。

sub start { 
    my $self = shift;
　　　　：
　　　　：
    die 'cannot start another process while you are in child process'
        if $self->{in_child};
　　　　：
}

0.10以上のParallel::Preforkを利用している場合には、上記の$pm->start(sub{})の中が
Parallel::Prefork側の$cbに入り、$cb->();実行後に、$self->finish();されているので、問題ない。

sub start {
    my ($self, $cb) = @_;
　　　　：
　　　　：
       if ($cb) {
           $cb->();
           $self->finish();
       }
　　　　：
}

ということで、コードをそのままに、libの読み込み先を

use lib "$FindBin::Bin/Parallel-Prefork-0.08/lib/";
　　　　　　　　　　　　　　　　　　　　　　　　↓
use lib "$FindBin::Bin/Parallel-Prefork-0.13/lib/";

に変更したら、正常に動作しました。
まあ、通常はcpanmとかでParallel::Preforkを更新すればいいだけですね。
現時点の最新が、0.13なので、それにしてますが、多分Changesから見ると0.10以降なら何でも動くはず。

【もしも0.08のままいきたいなら】
コードを以下のように$pm->startの引数で渡すのを止めて、
かつ、$pm->finish;を明示的にするように修正すればいいだけですね

#!/usr/local/bin/env perl
use strict;
use warnings;
use FindBin;
use lib "$FindBin::Bin/Parallel-Prefork-0.08/lib/";
use Parallel::Prefork;

my $pm = Parallel::Prefork->new({
        max_workers => 2,
        trap_signals => {
            TERM => 'TERM',
        },
    });

while ($pm->signal_received ne 'TERM') {
    $pm->start;

    sleep(3);
    warn "end:" . time();

    $pm->finish;
}

まあ、そもそもが、Parallel::Preforkの0.10以上を利用していたシステムを
0.10未満のサーバに移植した(古いサーバに移設とかあまり無いですよね)とかしないと発生しないので、
この現象を調べる事になる人は、ほとんどいないと思いますけど。