Process.waitFor()、线程和 InputStreams

Question

在伪代码中，这就是我正在做的事情：

Process proc = runtime.exec(command);
processOutputStreamInThread(proc.getInputStream());
processOutputStreamInThread(proc.getErrorStream());
proc.waitFor()

但是，有时processOutputStreamInThread 看不到任何输出，有时却看到了。粗略地说，该方法会创建命令输出的BufferedInputStream 并将其发送到记录器。

根据我所看到的，我猜测 command 不需要将其所有输出转储到由 getInputStream() 和 getErrorStream() 提供的流中，从而允许流为空。

我的试验结果如下：

(1) java.lang.Process 中的 waitFor() 是否要求执行程序的输出在返回之前已被读取？

文档仅说明：

使当前线程在必要时等待，直到此Process 对象表示的进程终止。如果子进程已经终止，则此方法立即返回。如果子进程尚未终止，则调用线程将被阻塞，直到子进程退出。

(2)getInputStream和getErrorStream提供的流在什么情况下需要关闭和/或自动关闭？

文档仅说明：

获取子进程的错误流。流从这个 Process 对象表示的进程的错误输出流中获取数据。

实现说明：缓冲输入流是个好主意。

一个user reports 说他必须自己关闭流，但至少在部分时间我得到一个异常，表明当我尝试这样做时流已经关闭。

编辑：将getOutputStream 更改为getInputStream，现在出现在上面。

解决方案：问题最终是在某些情况下，用于处理输出流的线程直到我的非常短暂的进程完成后才会运行，从而导致输入流给出我没有数据。 waitFor 没有等待执行程序的输出。相反，程序在收集任何输出之前运行并终止。

我使用线程是因为我不确定我将在标准错误和标准输出上获得多少输出，并且我希望能够同时处理两者，而不会阻塞其中一个或另一个应该只有其中一个有数据可用的。但是，因为我的线程不能始终如一地读取执行程序的输出，所以这是一个非解决方案。

我的最终编码看起来像这样：

ProcessBuilder pb = new ProcessBuilder(cmdargs);
pb.redirectErrorStream(true);
Process proc = pb.start();
processOutputStream(proc.getInputStream());
proc.waitFor()

Answer 1

如果您的外部进程在其stdin 上需要某些东西，您必须关闭getOutputStream。否则你将永远waitFor。

这里是来自 JavaWorld 的 When Runtime.exec() won't article，它描述了 exec 方法的不同陷阱以及如何避免它们。

根据我的经验，最好使用子进程的 STDOUT 和 STDERR（直到它们 EOF），然后阻止 waitFor。希望此时您不必等待太久。

对 Kaleb 问题的回答。 在正常情况下，您不应该关闭流，但是因为您是 waitingFor 并且无论出于何种原因它都没有超时，如果您在输出中遇到一些错误情况并且不想要，您可能需要关闭这些流进一步处理孩子的输出。但是，子程序是否会在其 STDOUT 或 STDERR 管道在另一端关闭时终止（崩溃）完全取决于该子程序的实现。但是，大多数 shell 程序都会在这种情况下终止。

我真的希望waitFor 有一些有意义的超时，并且当您决定放弃其监控时，Process 有记录的方式来清理其资源。

Answer 2

我认为这有点违反直觉，但是：

getOutputStream 获取输出 子进程的流。输出到 流被输送到标准 进程的输入流 由这个 Process 对象表示。 实施说明：这是个好主意 用于缓冲输出流。 返回：连接的输出流 到子进程的正常输入。

我将其作为主进程的输出流读取并附加到子进程的标准输入，因此当您写入 getOutputStream().write() 时，您实际上是在标准输入上写入。

你可能想使用 .getInputStream() 吗？

返回： 连接到子进程正常输出的输入流。

对于 Process.Waitfor()，API 文档说：

使当前线程等待，如果 必要的，直到过程 由这个 Process 对象表示有 终止。该方法返回 如果子流程有 已经终止。如果子进程 尚未终止，调用 线程将被阻塞，直到 子进程退出。

我会说这个被调用的线程将被阻塞，直到进程完成执行 - 您可能仍在此阶段处理输出，具体取决于其他线程，或者它们可能在您的线程返回之前完成。