Làm thế nào tôi có thể làm cho Perl chờ đợi cho các tiến trình con bắt đầu trong nền với hệ thống()?

Question

Tôi có một số mã Perl mà thực hiện một kịch bản shell cho nhiều thông số, để đơn giản hóa, tôi sẽ chỉ cho rằng tôi có mã trông như thế này:

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

Tôi muốn làm một số việc hơn sau điều đó, nhưng tôi không thể tìm được cách để chờ tất cả các quy trình con hoàn thành trước khi tiếp tục.

Việc chuyển đổi mã để sử dụng fork() sẽ rất khó khăn. Không phải là một cách dễ dàng hơn?

Answer 1

Dùng nĩa/exec/wait không quá tệ:

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

Chuyển đổi thành ngã ba() có thể khó, nhưng đó là công cụ chính xác. system() là một cuộc gọi chặn; bạn đang nhận được hành vi không chặn bằng cách thực hiện một trình bao và yêu cầu nó chạy các tập lệnh của bạn trong nền. Điều đó có nghĩa là Perl không biết PID của trẻ có thể là gì, điều đó có nghĩa là kịch bản của bạn không biết phải chờ đợi điều gì.

Bạn có thể cố gắng truyền đạt các PID đến kịch bản Perl, nhưng nhanh chóng bị mất. Sử dụng fork().

Answer 3

Bạn sẽ phải thay đổi thứ gì đó, thay đổi mã để sử dụng fork có thể đơn giản hơn, nhưng nếu bạn đã chết trước khi sử dụng fork, bạn có thể sử dụng script shell wrapper khi nó được thực hiện và sau đó có kiểm tra mã Perl của bạn cho sự tồn tại của các tập tin.

Đây là wrapper:

#!/bin/bash 

$* 

touch /tmp/$2.$PPID 

Perl code của bạn sẽ trông giống như:

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

Nhưng tôi nghĩ rằng mã forking là an toàn hơn và rõ ràng hơn:

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