Java教程

Java-Process执行脚本,waitFor()卡住不执行

本文主要是介绍Java-Process执行脚本,waitFor()卡住不执行,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

以脚本解压tar文件为例,如果tar包的生成时间在系统时间之后的话,解压就会有很多错误日志,使用java进行解压时,如果没有及时处理input或者是error缓冲区里的数据,那么等到缓冲区中数据满了(主要是error缓冲区)之后,解压操作就不会再继续进行下去了,因此要在解压过程中及时的将缓冲区中的数据清空,防止因为缓冲区爆满导致的解压失败;最终的解决方法是使用两个线程,在解压过程中对缓冲区中的数据读出。

解决代码如下:

public static String getCmdExecuteString(String cmdCommand) throws IOException, InterruptedException {

     StringBuilder sb = new StringBuilder();
     Process ps = cmdCommandExecute(cmdCommand);

     try (InputStreamReader ir = new InputStreamReader(ps.getInputStream());
          InputStreamReader er = new InputStreamReader(ps.getErrorStream());
          LineNumberReader input = new LineNumberReader(ir);
          LineNumberReader error = new LineNumberReader(er)) {

         new Thread(() -> {
             try {
                 String line;
                 while ((line = input.readLine()) != null) {
                     sb.append(line);
                     sb.append("\n");
                 }
             } catch (Exception e) {
                 if (!"Stream closed".equals(e.getMessage())) {
                     log.error(e.getMessage(), e);
                 }
             }
         }).start();

         new Thread(() -> {
             try {
                 String line;
                 while ((line = error.readLine()) != null) {
                     sb.append(line);
                     sb.append("\n");
                 }
             } catch (Exception e) {
                 if (!"Stream closed".equals(e.getMessage())) {
                     log.error(e.getMessage(), e);
                 }
             }
         }).start();

         int status = ps.waitFor();
         log.debug("get cmd execute status is {}", status);
         String result = sb.toString();
         log.debug("get cmd execute result is {}", result);
         return result;
     } finally {
         ps.destroy();
     }
}
这篇关于Java-Process执行脚本,waitFor()卡住不执行的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!