Блокировка ввода в Java

Question

Я новичок в Java, поэтому извиняюсь за то, что, вероятно, очень наивный вопрос. Я пишу приложение, которое будет общаться с несколькими другими процессами. Последний будет читать и писать с stdin и stdout. Я хотел бы перенаправить их ввод и вывод в файлы конкретных процессов и читать и писать оттуда.

У меня, похоже, проблемы с читающей частью. В частности, если данные еще не появились во входном файле, то InputStream.read(), кажется, возвращает -1, а не ждет его. Я немного искал решение, и все, что я нашел, похоже, указывает на то, что проблема заключается в том, что преждевременное закрытие потока. Я не думаю, что я это делаю.

Вот некоторые фрагменты соответствующего кода:

class Player { 
    public Player(String Infile, String Outfile, int initBankRoll) { 
      File inFile; 
      File outFile; 

      try { 
       reader = new FileInputStream(Infile); 
      } 
      catch (IOException ioe) { 
       System.err.println("Could not open " + Infile); 
       } 
    ... 
    } 

    public String readln() { 
     StringBuilder sb = new StringBuilder(80); 
     int i; 
     try { 
      while ((i = reader.read()) != '\n') { 
     sb.append(i); 
      } 
     } catch (IOException ioe) { 
      System.err.println("Could not read from file."); 
     } 
    return sb.toString(); 
    } 

Для чего это стоит, я предпочел бы иметь быстрое решение, чем элегантный один. Спасибо за любую помощь, которую любой может предоставить!

Ох - это может быть актуально. Я пытаюсь проверить отправку на входе, набрав кота -> TestFile на терминале ...

Answer 1

Я не знаю, я понимаю ваш вопрос правильно, но в основном вы хотите читать строки из файла, и если есть нет другой линии, вы хотите подождать? Правильно?

Если да, то это может быть решение:

public static void main(String [] args) 
{ 
    Player player = new Player("C:\\Data\\test.txt"); 
    while(true) {//do whatever condition you want here 
     System.out.println("Write:"); 
     String line = player.readln(); 
     System.out.println(line); 
    } 
} 
public class Player { 
    BufferedReader bufferedReader; 

    public Player(String fileName) { 
     try { 
      bufferedReader = new BufferedReader(new InputStreamReader(new FileInputStream(fileName), Charset.forName("UTF-8"))); 
     } 
     catch (IOException ioe) { 
      System.err.println("Could not open " + fileName); 
     } 
    } 

    public String readln() { 
     String line = null; 
     try { 
      while(true){ //this will wait till new line in file 
       if((line = bufferedReader.readLine())!= null) 
        return line; 
      } 
     } catch (IOException ioe) { 
      System.err.println("Could not read from file."); 
     } 
     return line; 
    } 
}