worker が全員仕事を終えた後に postman プロセスに undef を送ってやれば正しく終了するんじゃないかと思って適当にやってみたら、ちゃんと動いた。
# 終わったらコロ助
for ($c = 0; $c < $maxth; $c++) {
$kids[$c]->join;
}
$m->join;
$qo->enqueue(undef);
$p->join;
print "done.\n";
}
worker が全員仕事を終えた後に postman プロセスに undef を送ってやれば正しく終了するんじゃないかと思って適当にやってみたら、ちゃんと動いた。
# 終わったらコロ助
for ($c = 0; $c < $maxth; $c++) {
$kids[$c]->join;
}
$m->join;
$qo->enqueue(undef);
$p->join;
print "done.\n";
}
TrackBack URL: http://blog.woremacx.com/MT/mt-tb.cgi/39
Leave a comment