在 Java 中，BufferedReader readLine 在交互式 shell 上阻塞

Question

我有一个 jar 文件，它一直在等待用户输入、处理和打印结果（多行），就像这样

>Input sentence 1
Result 1
Result 2
>Input sentence 2
Result 1
Result 2
Result 3
>

退出这个jar程序的唯一方法是按Ctrl + C。

现在，我想从我的 java 程序中调用这个 jar 文件。我的代码如下所示：

processBuilder = new ProcessBuilder(PATH_TO_BIN);
Process process = processBuilder.start();
writer = new BufferedWriter(new OutputStreamWriter(process.getOutputStream()));
reader = new BufferedReader(new InputStreamReader(process.getInputStream()));

writer.write(inputSentence);
writer.newLine();
writer.flush();
String line;
while ((line = reader.readLine()) != null){ //<<<< it hangs here
    System.out.println(line);
}

我的程序可以成功打印出“jar”程序返回的结果，但是一直挂在下一个reader.readLine()，我无法为“jar”程序提供下一个输入。

有没有办法解决这个问题？

提前致谢！

Answer 1

您可以使用一个线程读取和另一个写入，然后它不会在读取时阻塞，如下所示：

    ProcessBuilder processBuilder = new ProcessBuilder(PATH_TO_BIN);
    Process process = processBuilder.start();
    BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(process.getOutputStream()));

      
    new Thread () {
      public void run() {
        BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()));
        String line = null;
        do {             
          line = reader.readLine();
          System.out.println(line);
        } while (line != null); // <<<< it waits here for next line of input 
      }
    }.start();
       

    // and here you can write something to the process InputSteram...
    writer.write(inputSentence);
    writer.newLine();
    writer.flush();

Answer 2

来自 BufferedReader 的方法 ready() - 判断该流是否准备好被读取。

您可以使用此方法检查流是否已准备好被读取，如果是，您可以完成您的工作，

while (reader.ready()){
//Do the processing
}

看看这是否有效。

Answer 3

我将以 @Krzystof 的回答为基础，但我假设您将使用 Java 7 或 8 (+)。

在这种情况下，您应该使用 Try-With-Resources，如下所示：

public static void main (String[] args) throws java.lang.Exception {

    ProcessBuilder prBuilder = new ProcessBuilder("/path/to/bin");
    Process process = prBuilder.start();
    try (BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream())) | BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(process.getOutputStream()))) {

        String line;

        while ((line = reader.readLine()) != null) {
            // Process input
        }

    } catch (IOException ex) {
        // Process IOException
    } finally {
        process.kill();
    }
}