java process waitfor 卡主的问题

红太狼 2022-08-24 05:14 145阅读 0赞

http://yearsaaaa123789.iteye.com/blog/1404865

在编写Java程序时，有时候我们需要调用其他的诸如exe,shell这样的程序或脚本。在Java中提供了两种方法来启动其他程序：(1) 使用Runtime的exec()方法(2) 使用ProcessBuilder的start()方法 。Runtime和ProcessBulider提供了不同的方式来启动程序，设置启动参数、环境变量和工作目录。但是这两种方法都会返回一个用于管理操作系统进程的Process对象。这个对象中的waitFor()是我们今天要讨论的重点。

来说说我遇到的实际情况：我想调用ffmpeg程序来对一首歌曲进行转码,把高音质版本的歌曲转为多种低码率的文件。但是在转码完成之后需要做以下操作：读取文件大小，写入ID3信息等。这时我们就想等转码操作完成之后我们可以知道。

如下这样代码

Process p = null;
    try {
    	p = Runtime.getRuntime().exec("notepad.exe");
    } catch (Exception e) {
    	e.printStackTrace();
    }
    System.out.println("我想被打印...");

在notepad.exe被执行的同时，打印也发生了，但是我们想要的是任务完成之后它才被打印。

之后发现在Process类中有一个waitFor()方法可以实现。如下：

Process p = null;
    try {
    	p = Runtime.getRuntime().exec("notepad.exe");
    	p.waitFor();
    } catch (Exception e) {
    	e.printStackTrace();
    }
    System.out.println("我想被打印...");

这下又出现了这样的现象，必须要等我们把记事本关闭打印语句才会被执行。并且你不碰手动关闭它那程序就一直不动，程序貌似挂了....![icon_cry.gif][].这是什么情况，想调用个别的程序有这么难吗?让我们来看看waitFor()的说明：

JDK帮助文档上这么说：如有必要，一直要等到由该 Process 对象表示的进程已经终止。如果已终止该子进程，此方法立即返回。但是直接调用这个方法会导致当前线程阻塞，直到退出子进程。对此JDK文档上还有如此解释：因为本地的系统对标准输入和输出所提供的缓冲池有效，所以错误的对标准输出快速的写入何从标准输入快速的读入都有可能造成子进程的所，甚至死锁。好了，问题的关键在缓冲区这个地方：可执行程序的标准输出比较多，而运行窗口的标准缓冲区不够大，所以发生阻塞。接着来分析缓冲区，哪来的这个东西,当Runtime对象调用exec(cmd)后，JVM会启动一个子进程，该进程会与JVM进程建立三个管道连接：标准输入，标准输出和标准错误流。假设该程序不断在向标准输出流和标准错误流写数据，而JVM不读取的话，当缓冲区满之后将无法继续写入数据，最终造成阻塞在waitfor()这里。 知道问题所在，我们解决问题就好办了。查看网上说的方法多数是开两个线程在waitfor()命令之前读出窗口的标准输出缓冲区和标准错误流的内容。代码如下：

Runtime rt = Runtime.getRuntime();
    String command = "cmd /c ffmpeg -loglevel quiet -i "+srcpath+" -ab "+bitrate+"k -acodec libmp3lame "+desfile;
    try {
     p = rt.exec(command ,null,new File("C:\\ffmpeg-git-670229e-win32-static\\bin"));
     //获取进程的标准输入流
     final InputStream is1 = p.getInputStream(); 
     //获取进城的错误流
     final InputStream is2 = p.getErrorStream();
     //启动两个线程，一个线程负责读标准输出流，另一个负责读标准错误流
     new Thread() {
        public void run() {
           BufferedReader br1 = new BufferedReader(new InputStreamReader(is1));
            try {
                String line1 = null;
                while ((line1 = br1.readLine()) != null) {
                      if (line1 != null){}
                  }
            } catch (IOException e) {
                 e.printStackTrace();
            }
            finally{
                 try {
                   is1.close();
                 } catch (IOException e) {
                    e.printStackTrace();
                }
              }
            }
         }.start();
                                  
       new Thread() { 
          public void  run() { 
           BufferedReader br2 = new  BufferedReader(new  InputStreamReader(is2)); 
              try { 
                 String line2 = null ; 
                 while ((line2 = br2.readLine()) !=  null ) { 
                      if (line2 != null){}
                 } 
               } catch (IOException e) { 
                     e.printStackTrace();
               } 
              finally{
                 try {
                     is2.close();
                 } catch (IOException e) {
                     e.printStackTrace();
                 }
               }
            } 
          }.start();  
                                  
          p.waitFor();
          p.destroy(); 
         System.out.println("我想被打印...");
        } catch (Exception e) {
                try{
                    p.getErrorStream().close();
                    p.getInputStream().close();
                    p.getOutputStream().close();
                    }
                 catch(Exception ee){}
              }
       }

这个方法确实可以解决调用waitFor()方法阻塞无法返回的问题。但是在其中过程中我却发现真正起关键作用的缓冲区是getErrorStream()说对应的那个缓冲区没有被清空，意思就是说其实只要及时读取标准错误流缓冲区的数据程序就不会被block。

[icon_cry.gif]: /images/20220823/680d4347d2044296bf5f939f0b64125e.png