2

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

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

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;

有没有被终止waitFor的可能？Thread

4

2 回答 2

1

这是做你想做的事情的一般代码。在这种情况下，既有输入也有输出：我someFile将管道输入流程并将输出管道传输到System.out. Files.copy()并且ByteStreams.copy()只是将一个InputStream连接到一个OutputStream. 然后我们等待命令完成。

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);
于 2013-03-18T17:17:45.843 回答
1

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

于 2013-03-18T17:29:30.057 回答