Как я могу заставить Perl ждать дочерних процессов, запущенных в фоновом режиме с помощью system()?

Question

У меня есть некоторый код Perl, который выполняет сценарий оболочки для нескольких параметров, чтобы упростить, я просто предположу, что у меня есть код, который выглядит следующим образом:

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

Я хотел бы сделать еще несколько вещей после это, но я не могу найти способ дождаться завершения всех дочерних процессов, прежде чем продолжить.

Преобразование кода для использования fork() будет затруднительным. Разве нет более простого пути?

Answer 1

Используя вилку/exec/wait не так уж плохо:

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

Преобразование в fork() может быть затруднено, но это правильный инструмент. system() - блокирующий вызов; вы получаете неблокирующее поведение, выполняя оболочку и сообщая ей, чтобы запустить ваши сценарии в фоновом режиме. Это означает, что Perl не знает, что такое PID от детей, а это значит, что ваш скрипт не знает, чего ждать.

Вы можете попытаться передать PID до Perl-скрипта, но это быстро выходит из-под контроля. Используйте fork().

Answer 3

Вам нужно что-то изменить, изменение кода для использования fork, вероятно, проще, но если вы мертвы против использования fork, вы можете использовать сценарий оболочки оболочки, который касается файла, когда это будет сделано, а затем проверьте свой код Perl на наличие файлов.

Вот обертка:

#!/bin/bash 

$* 

touch /tmp/$2.$PPID 

Ваш код Perl будет выглядеть следующим образом:

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

Но я думаю, что код разветвление безопаснее и понятнее:

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; 
}