java - 当批处理的输出太大时，Process.getErrorStream() 不起作用

Question

static String getTime(String command) throws IOException, Throwable{
    try{
        String completeComm=Userdir+"\\timer.bat";
        Process p=Runtime.getRuntime().exec("cmd /c "+completeComm+" "+command+" --batch");

        BufferedReader reader=new BufferedReader (new InputStreamReader(p.getInputStream()));       

        LineIterator l=IOUtils.lineIterator(reader);            
        try {
            while (l.hasNext()) {
                String line = l.nextLine();
                System.out.println(line);
                ...
                }
            }
        } finally {
            LineIterator.closeQuietly(l);
        }

        BufferedReader Ereader=new BufferedReader (new InputStreamReader(p.getErrorStream()));
        LineIterator El=IOUtils.lineIterator(Ereader);          
        try {
            while (El.hasNext()) {
                String line = El.nextLine();
                System.out.println(line);
                ...
                }
            }
        } finally {
            LineIterator.closeQuietly(El);
        }


    }catch(Exception e){
        JOptionPane.showMessageDialog(null, e.getMessage());
        System.exit(0);
    }
}

我的问题是“p.getStreamError”。仅当我的批处理文件的输出/结果不是数百或数千行时，我才能看到 p.getStreamError 的输出，否则我不会得到任何输出(p.getSTreamError)。

1. 为什么当我的批处理的返回结果/数据很大时，我无法从 p.getStreamError 获得任何输出？

2. 当我创建一个 jar 并运行它时，程序永远挂起。我调试了它，发现它卡在了“while (El.hasNext())”处。为什么程序在通过 jar 运行时挂起并在 eclipse 中运行良好？

谢谢!

Answer 1

您需要为 while 循环使用单独的线程。

考虑创建一个实现 Runnable 的 StreamGobbler 类，该类在其构造函数中采用 InputStream，并且在其 run 方法中具有您的 while 循环。然后用这些 Gobbler 创建线程并让它们运行。

类似于:

public class StreamGobbler implements Runnable {
   private static String userdir;
   private String name;
   private LineIterator lineIterator;

   public StreamGobbler(String name, InputStream inStream) {
      this.name = name;
      BufferedReader bufReader = new BufferedReader(new InputStreamReader(
            inStream));
      lineIterator = IOUtils.lineIterator(bufReader);
   }

   @Override
   public void run() {
      try {
         while (lineIterator.hasNext()) {
            String line = lineIterator.nextLine();
            System.out.println(line);
            // ...
         }

      } finally {
         LineIterator.closeQuietly(lineIterator);
      }

   }

   public String getName() {
      return name;
   }
}

然后它可以像这样使用:

String completeComm = userdir + "\\timer.bat";
Process p = Runtime.getRuntime().exec(
       "cmd /c " + completeComm + " " + command + " --batch");
new Thread(new StreamGobbler("InputStream", p.getInputStream())).start();
new Thread(new StreamGobbler("ErrorStream", p.getErrorStream())).start();