perl - AnyEvent::Fork 如何等待 child

我正在查看 AnyEvent::Fork 模块。我有 20 个外部脚本，我想并行调用(一次 6 个)，并在全部完成后汇总它们的输出。我不知道如何实现这一目标。

模块中的示例代码(仅调用 1 个 child )有问题。我只是在代码中添加了一个简单的 sleep 来不立即返回并且父进程立即退出而不等待子进程。

open my $output, ">/tmp/log" or die "$!";

AnyEvent::Fork
   ->new
   ->eval ('
        # compile a helper function for later use
        sub run {
           my ($fh, $output, @cmd) = @_;

           # perl will clear close-on-exec on STDOUT/STDERR
           open STDOUT, ">&", $output or die;
           open STDERR, ">&", $fh or die;

           ### Added by me to demonstrate that
           ### $cv->recv returns immediately.
           sleep 5;

           exec @cmd;
        }
     ')
   ->send_fh ($output)
   ->send_arg ("/bin/echo", "hi")
   ->run ("run", my $cv = AE::cv);

my $stderr = $cv->recv;

结果是 /tmp/log 为空。
我不明白 condvar 在这里是如何使用的，它不在文档中。我可以使用 condvar 获取正在运行的 child 的数量吗？

请帮助如何做到这一点。

UPDATE 这里的主要问题是父级不等待子级完成。

最佳答案

这里的问题是父进程和子进程是独立的进程，可以相互独立运行，所以如果一个应该等待另一个，则需要显式同步。有很多方法可以做到这一点，最简单的方法是使用 AnyEvent::Fork::RPC，然后向子进程发送一个“等待”请求，它在完成后响应。

要使用裸 AnyEvent::Fork 做到这一点，最简单的方法是利用 ->run 提供的双向管道:

  AnyEvent::Fork
    ->new
    ->run (sub {
       my ($fh) = @_;
       sysread $fh, my $dummy, 1; # will wait for data, or eof
       ... done, you can now call e.g. $cv->send

sysread 将尝试从 child 那里读取。如果子进程从不发送任何东西，这将阻塞父进程，直到子进程退出，因为在那一刻，子进程将关闭管道的末端并且 sysread 获得一个 EOF。

当然，在 AnyEvent 程序中，您可能不想阻塞，因此您使用 I/O 观察器:

 ->run (sub {
    my ($fh) = @_;
    my $rw; $rw = AE::io $fh, 0, sub {
       ... read data received, or EOF
       undef $rw;
       ... done, you can now call e.g. $cv->send;
    }
  });

这个技巧也可以用于外部命令(在你的例子中是 exec)，通过清除子进程中管道的 close-on-exec 状态，从而将它传递给 exec'ed 程序 - 在这种情况下，当所有程序继承管道导出，管道将发出 EOF 信号。

这应该让你开始。还有其他方法可以做到，但大多数甚至所有好的方法都会涉及一些通信管道，最容易获得的方法是使用 AnyEvent::Fork 提供的方法。

关于perl - AnyEvent::Fork 如何等待 child ，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/27153465/