Runtime.getRuntime().exec执行阻塞问题解决

冷不防 2022-05-31 01:54 693阅读 0赞

有时候我们可能需要调用系统外部的某个程序，此时就可以用Runtime.getRuntime().exec()来调用，他会生成一个新的进程去运行调用的程序。

此方法返回一个java.lang.Process对象，该对象可以得到之前开启的进程的运行结果，还可以操作进程的输入输出流。

Process对象有以下几个方法：

1、destroy()　　　　　　杀死这个子进程

2、exitValue()　　　 　　得到进程运行结束后的返回状态

3、waitFor()　　　　 　　得到进程运行结束后的返回状态，如果进程未运行完毕则等待知道执行完毕

4、getInputStream()　　得到进程的标准输出信息流

5、getErrorStream()　　得到进程的错误输出信息流

6、getOutputStream()　得到进程的输入流

现在来讲讲exitValue()，当线程没有执行完毕时调用此方法会跑出IllegalThreadStateException异常，最直接的解决方法就是用waitFor()方法代替。

但是waitFor()方法也有很明显的弊端，因为java程序给进程的输出流分配的缓冲区是很小的，有时候当进程输出信息很大的时候回导致缓冲区被填满，如果不及时处理程序会阻塞。如果程序没有对进程的输出流处理的会就会导致执行exec()的线程永远阻塞，进程也不会执行下去直到输出流被处理或者java程序结束。

解决的方法就是处理缓冲区中的信息，开两个线程分别去处理标准输出流和错误输出流。

处理方法：

Process p = Runtime.getRuntime().exec(cmdStr);  
//用于处理Runtime.getRuntime().exec产生的错误流及输出流 ,防止阻塞  
StreamGobbler errorGobbler = new StreamGobbler(p.getErrorStream(), "ERROR");                        
errorGobbler.start();            
StreamGobbler outGobbler = new StreamGobbler(p.getInputStream(), "STDOUT");      
outGobbler.start();       
p.waitFor();

StreamGobbler.java

package cn.rojao.utils;  
import java.io.BufferedReader;    
import java.io.IOException;    
import java.io.InputStream;    
import java.io.InputStreamReader;    
import java.io.OutputStream;    
import java.io.PrintWriter;    
/\*\*   
 \* 用于处理Runtime.getRuntime().exec产生的错误流及输出流   
 \*   
 \*/    
public class StreamGobbler extends Thread \{    
    InputStream is;    
    String type;    
    OutputStream os;    
    
    public StreamGobbler(InputStream is, String type) \{    
        this(is, type, null);    
    \}    
    
    StreamGobbler(InputStream is, String type, OutputStream redirect) \{    
        this.is = is;    
        this.type = type;    
        this.os = redirect;    
    \}    
        
    public void run() \{    
        InputStreamReader isr = null;    
        BufferedReader br = null;    
        PrintWriter pw = null;    
        try \{    
            if (os != null)    
                pw = new PrintWriter(os);    
                    
            isr = new InputStreamReader(is);    
            br = new BufferedReader(isr);    
            String line=null;    
            while ( (line = br.readLine()) != null) \{    
                if (pw != null)    
                    pw.println(line);    
                System.out.println(type + ">" + line);        
            \}    
                
            if (pw != null)    
                pw.flush();    
        \} catch (IOException ioe) \{    
            ioe.printStackTrace();      
        \} finally\{   
        pw.close();  
        try \{  
            br.close();  
            isr.close();   
\} catch (Exception e) \{  
e.printStackTrace();  
\}  
   
        \}    
    \}    
\}