Process.waitFor() 一个线程

Question

在运行外部脚本时，我想同时或分别读取该脚本的 ErrorStream 和 OutputStream，然后进一步处理它们。因此，我为其中一个流启动了Thread。不幸的是，Process 似乎并没有将waitFor 和Thread 终止，而是在非线程流没有进一步输入之后返回。

简而言之，这就是我正在做的事情：

ProcessBuilder pb = new ProcessBuilder(script);  
final Process p = pb.start();  

new Thread(new Runnable() {  
  public void run() {
    BufferedReader br = new BufferedReader(new InputStreamReader(p.getErrorStream()));
    ...read lines and process them...
  }
}).start();

BufferedReader br = new BufferedReader(new InputStreamReader(p.getInputStream()));
...read lines and process them...

int exitValue = p.waitFor();
p.getOutputStream().close();
return exitValue;

waitForThread有可能被终止吗？

Answer 1

您可以使用Thread.join(...) 等待Thread 完成。请注意，如果当前线程在您等待的线程完成之前收到中断，则调用将抛出 InterruptedException。

Answer 2

这是执行您想做的事情的一般代码。在这种情况下，既有输入也有输出：我将someFile 输送到流程中，并将输出输送到System.out。 Files.copy() 和ByteStreams.copy() 只是将InputStream 连接到OutputStream 的Guava 便捷方法。然后我们等待命令完成。

final Process pr = Runtime.getRuntime().exec(cmd);

new Thread() {
    public void run() {
        try (OutputStream stdin = pr.getOutputStream()) {
            Files.copy(someFile, stdin);
        } 
        catch (IOException e) { e.printStackTrace(); }
    }
}.start();

new Thread() {
    public void run() {
        try (InputStream stdout = pr.getInputStream()) {
            ByteStreams.copy(stdout, System.out);
        } 
        catch (IOException e) { e.printStackTrace(); }  
    }
}.start();              

int exitVal = pr.waitFor();
if( exitVal == 0 )
    System.out.println("Command succeeded!");
else    
    System.out.println("Exited with error code " + exitVal);

如果您在 Java 7 之前使用 try-with-resources 块运行，则更详细的版本：

final Process pr = Runtime.getRuntime().exec(cmd);

new Thread() {
    public void run() {
        OutputStream stdin = null;
        try {
            Files.copy(someFile, stdin = pr.getOutputStream());
        } 
        catch (IOException e) { e.printStackTrace(); }
        finally {
            if( stdin != null ) {
                try { stdin.close(); } 
                catch (IOException e) { e.printStackTrace(); }
            }
        }               
    }
}.start();

new Thread() {
    public void run() {
        InputStream stdout = null;
        try {
            ByteStreams.copy(stdout = pr.getInputStream(), System.out);
        } 
        catch (IOException e) { e.printStackTrace(); }
        finally {
            if( stdout != null ) {
                try { stdout.close(); } 
                catch (IOException e) { e.printStackTrace(); }
            }
        }               
    }
}.start();              

int exitVal = pr.waitFor();
if( exitVal == 0 )
    System.out.println("Command succeeded!");
else    
    System.out.println("Exited with error code " + exitVal);