perl-parallel-processing/

#!/usr/bin/perl
# parent.pl — (c) 2010 Alexandr A Alexeev, http://remontka.com/

use Socket ;
use IO :: Select ;
use IO :: Handle ;
use strict ;

my $select = IO :: Select -> new ( ) ;

# команды для запуска дочерних процессов
my @commands ; # («ls -la /», «pkg_info | grep p5-«);

print «List of commands: n n » ;

# тут заполняешь массив @commands
# while(1) {
#  my $cmd = «./child.pl arg1 arg2 arg3»;
#  print «$cmdn»;
#  push @commands, $cmd;
# }

print » n starting in 10 seconds… n n » ;
sleep 10 ;

for my $cmd ( @commands ) {
print «starting ‘$cmd’… n » ;
my ( $hchild , $hparent , $childid ) ;
socketpair ( $hchild , $hparent , AF_UNIX , SOCK_STREAM , PF_UNSPEC )
or die «socketpair: $!» ;

$childid = fork ;
die «cannot fork» if ( $childid == — 1 ) ;

# перенаправляем ввод/вывод потомка в сокет
unless ( $childid ) {
# потомок
open STDIN , «<&» , $hparent ;
open STDOUT , «>&» , $hparent ;
open STDERR , «>&» , $hparent ;
close $hparent ;
close $hchild ;
# унаследованные хэгдлы следует закрыть
$select -> remove ( $_ ) and close $_ for ( $select -> handles ) ;
exec $cmd ;
}

close $hparent ;
$select -> add ( $hchild ) ;
}

print «All done, now reading… n » ;

while ( my @ready = $select -> can_read ) {
# кто-то из потомков завершился или что-то написал в stdout
for my $read ( @ready ) {
if ( $read -> eof || $read -> error ) {
# потомок завершил работу
$select -> remove ( $read ) ;
close $read ;
next ;
}
if ( my $str = < $read > ) {
print $str ;
# обрабатываем строку $str
}
}
}

#!/usr/bin/perl

use strict ;

$| = 1 ; # <— архиважная строчка, отключающая буферизацию вывода

# здесь тупо парсим аргументы и выводим все, что надо в stdout