Come posso fare in modo che Perl aspetti i processi figli avviati in background con system()?

Question

Ho qualche codice Perl che esegue uno script di shell per più parametri, per semplificare, mi limiterò a supporre che Ho codice che assomiglia a questo:

for $p (@a){ 
    system("/path/to/file.sh $p&"); 
} 

mi piacerebbe fare alcune più cose dopo questo, ma non riesco a trovare un modo per attendere che tutti i processi figli finiscano prima di continuare.

Conversione del codice per utilizzare fork() sarebbe difficile. Non c'è un modo più semplice?

Answer 1

utilizzando fork/exec/wait non è poi così male:

my @a = (1, 2, 3); 
for my $p (@a) { 
    my $pid = fork(); 
    if ($pid == -1) { 
     die; 
    } elsif ($pid == 0) { 
     exec '/bin/sleep', $p or die; 
    } 
} 
while (wait() != -1) {} 
print "Done\n"; 

Answer 2

La conversione in fork() potrebbe essere difficile, ma è lo strumento corretto. system() è una chiamata bloccante; stai ottenendo il comportamento non bloccante eseguendo una shell e dicendogli di eseguire i tuoi script in background. Ciò significa che Perl non ha idea di cosa possano essere i PID dei bambini, il che significa che il tuo script non sa cosa aspettare.

Si potrebbe provare a comunicare i PID fino allo script Perl, ma ciò rapidamente sfugge. Usa la forchetta().

Answer 3

Dovrai cambiare qualcosa, cambiare il codice per usare fork è probabilmente più semplice, ma se sei morto contro l'uso di fork, puoi usare uno script di shell wrapper che tocchi un file quando è finito e poi controlla il codice Perl per l'esistenza dei file.

Ecco l'involucro:

#!/bin/bash 

$* 

touch /tmp/$2.$PPID 

Il codice Perl sarà simile:

for my $p (@a){ 
    system("/path/to/wrapper.sh /path/to/file.sh $p &"); 
} 
while (@a) { 
    delete $a[0] if -f "/tmp/$a[0].$$"; 
} 

ma penso che il codice di biforcazione è più sicuro e più chiara:

my @pids; 
for my $p (@a) { 
    die "could not fork" unless defined(my $pid = fork);\ 
    unless ($pid) { #child execs 
     exec "/path/to/file.sh", $p; 
     die "exec of file.sh failed"; 
    } 
    push @pids, $pid; #parent stores children's pids 
} 

#wait for all children to finish 
for my $pid (@pids) { 
    waitpid $pid, 0; 
}