Inline::Java 与 Parallel::ForkManager 冲突

Question

我在同时调用 Parallel::ForkManager 和 Inline::Java 时遇到问题。具体来说，如果我使用 JNI => 调用 Inline::Java ， 1 选项（我必须这样做），那么 fork 进程不会返回到父进程。以下是代码：

use Parallel::ForkManager;

##### Calling Inline::Java #####
use Inline Java => <<END, JNI => 1;

END
###### End of Inline::Java #####

my $pm = Parallel::ForkManager->new(2);
for my $i (0..1) {
    $pm->start and next;
    print "Inside process $i\n";
    $pm->finish;
}
$pm->wait_all_children;
print "Back to Parent.\n";

如果我运行这个程序，它会进入子进程，但永远不会返回父进程。如果我删除注释之间的 3 行，它就可以正常运行。如果我更改 JNI => 1 到 JNI => 0（并不是说我可以出于我的目的更改该参数），然后出现错误消息 Lost connection with Java virtual machine at /usr/lib64/perl5/site_perl/5.8.8 /x86_64-linux-thread-multi/Inline/Java.pm 第 975 行。

有谁知道如何解决冲突？我还必须在并行过程之前调用 Inline::Java，因此在并行完成后使用 require 不是一个选项。谢谢！

Answer 1

每个孩子都通过同一个套接字进行通话，这会导致虚拟机接收到乱码。

您需要延迟与虚拟机的连接，以便在子级而不是父级中完成。

您可以将所有与 Inline::Java 相关的内容移动到另一个模块中，然后在 start 之后使用 require Child; （而不是 use Child;）。

如果您需要在启动子进程之前使用 Inline::Java，请在不同的进程中执行此操作。

Answer 2

在 Inline::Java 中使用 fork 将会是一个问题。您的 Perl 脚本需要与 JVM 保持 TCP 连接。当您分叉一个新进程时，用于与 JVM 通信的相同文件描述符将传递给子进程，因此父进程和所有子进程都使用相同的套接字。那是行不通的。您需要重新设计您的应用程序。

一种可能性（您已经排除了这种可能性）是延迟启动 JVM，直到分叉之后，在每个子进程中启动一个新的 JVM。

另一种方法是忘记从 Perl 派生并利用 Java 的高级线程模型来进行并行化。设计您的 Java 代码以在新线程中执行其任务，并从 Perl 启动新线程：

my $java = ... entry point to JVM ...

for my $n (1 .. $num_threads) {
    $java->startNewThread(@inputs)
}
$java->waitForThreadsToFinish();
$result = $java->getResults();

Perl 也有自己的线程模型（请参阅 线程 和 threads::shared）。我怀疑 Perl 的线程能否解决这个问题，但它仍然值得一试。

---

更新： Inline::Java docs 是使用共享JVM。使用选项 SHARED_JVM => 调用 Inline::Java 1，当新的子进程启动时，从子进程中调用 Inline::Java::reconnect_JVM() 来建立新的连接。这种方法的缺点是

1. 它在程序结束后使 JVM 保持活动状态，因此您必须记住杀死 JVM，
2. 因为它与选项 JNI =>; 不兼容。 1，这可能会破坏OP的交易。