Runtime.getRuntime（）。exec（cmd）掛起

Question

我正在執行一個命令，它返回一個文件的版本號; '文件名'。但是如果執行該命令時出現問題，則應用程序掛起。我能做些什麼來避免這種情況？請在下面找到我的代碼。

String cmd= "cmd /C si viewhistory --fields=revision --project="+fileName; 
Process p = Runtime.getRuntime().exec(cmd) ; 
BufferedReader in = new BufferedReader(new InputStreamReader(p.getInputStream())); 
String line = null; 
while ((line = in.readLine()) != null) { 
System.out.println(line); 
} 

} catch (Exception e) { 
e.printStackTrace(); 
} 

Answer 1

我想問題是，你只讀取InputStream而不讀取ErrorStream。您還必須小心並行讀取兩個流。可能發生的情況是，當前從輸出流傳輸的數據填充OS緩衝區，您的exec命令將自動暫停，以便讀者有機會清空緩衝區。但該程序仍將等待輸出處理。因此，掛起發生。

您可以創建一個單獨的類來處理在輸入和錯誤流如下，

public class ReadStream implements Runnable { 
    String name; 
    InputStream is; 
    Thread thread;  
    public ReadStream(String name, InputStream is) { 
     this.name = name; 
     this.is = is; 
    }  
    public void start() { 
     thread = new Thread (this); 
     thread.start(); 
    }  
    public void run() { 
     try { 
      InputStreamReader isr = new InputStreamReader (is); 
      BufferedReader br = new BufferedReader (isr); 
      while (true) { 
       String s = br.readLine(); 
       if (s == null) break; 
       System.out.println ("[" + name + "] " + s); 
      } 
      is.close();  
     } catch (Exception ex) { 
      System.out.println ("Problem reading stream " + name + "... :" + ex); 
      ex.printStackTrace(); 
     } 
    } 
} 

您使用它是如下的方式，

String cmd= "cmd /C si viewhistory --fields=revision --project="+fileName; 
Process p = Runtime.getRuntime().exec(cmd) ; 
s1 = new ReadStream("stdin", p.getInputStream()); 
s2 = new ReadStream("stderr", p.getErrorStream()); 
s1.start(); 
s2.start(); 
p.waitFor();   
} catch (Exception e) { 
e.printStackTrace(); 
} finally { 
    if(p != null) 
     p.destroy(); 
} 

Answer 2

這個代碼是基於同樣的想法Arham的答案，但是使用java 8並行流實現，這使得它更加簡潔。

public static String getOutputFromProgram(String program) throws IOException { 
    Process proc = Runtime.getRuntime().exec(program); 
    return Stream.of(proc.getErrorStream(), proc.getInputStream()).parallel().map((InputStream isForOutput) -> { 
     StringBuilder output = new StringBuilder(); 
     try (BufferedReader br = new BufferedReader(new InputStreamReader(isForOutput))) { 
      String line; 
      while ((line = br.readLine()) != null) { 
       output.append(line); 
       output.append("\n"); 
      } 
     } catch (IOException e) { 
      throw new RuntimeException(e); 
     } 
     return output; 
    }).collect(Collectors.joining()); 
} 

可以調用方法這樣

getOutputFromProgram("cmd /C si viewhistory --fields=revision --project="+fileName); 

注意的是，如果需要輸入這個方法，如果程序您呼叫掛起掛起，這會發生。