Runtime.getRuntime(). Exec (cmd) asılı

Question

Bir dosyanın Revizyon numarasını döndüren bir komut yürütüyorum; 'dosya adı'. Ancak, komutun çalıştırılmasında bir sorun varsa, uygulama kilitlenir. Bu durumdan kaçınmak için ne yapabilirim? Lütfen kodumu aşağıda bulabilirsiniz.

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

Sorun şu ki, yalnızca InputStream okuyorsunuz ve ErrorStream okumadığınız içindir. Ayrıca, her iki akışın da paralel olarak okunmasına dikkat etmelisiniz. Halihazırda çıktı akışından aktarılan verilerin işletim sistemi tamponunu doldurması, okuyucunuzun arabelleği boşaltma şansı vermesi için otomatik olarak askıya alınacaktır. Ama program hala çıktıların işlenmesini bekliyor olacak. Bu nedenle asılma gerçekleşir. Bu kod dayanmaktadır

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

aşağıdaki gibi giriş ve Hata Akış hem işlemek için ayrı bir sınıf oluşturabilir

,

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(); 
     } 
    } 
} 

aşağıdaki gibi öyle kullanmak yolu, Aynı fikir Arham'ın cevabı, ama bir java 8 paralel akışı kullanılarak uygulanır, bu biraz daha özlü yapar.

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()); 
} 

Sen program kilitleniyor aradığınız eğer girdi gerektiriyorsa bu yöntem gerçekleşecek olan askıda olacağı bu

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

Not gibi yöntemini çağırabilirsiniz.