È Java FileInputStream Locking File per la scrittura

Question

Sto creando un bridge veloce tra due programmi separati.

Un programma scrive su un file, mentre il mio programma legge contemporaneamente da esso.

Sembra che non appena chiamo la prima lettura la scrittura sia completamente bloccata.

Perché si verifica questo e qual è la soluzione?

// Create Named Pipe 
Runtime.getRuntime.exec("mkfifo /tmp/mypipe") 

val stream = new FileInputStream("/tmp/mypipe") 

val in = new BufferedReader(new InputStreamReader(stream)) 

// File opened for reading. No blocking at this point. 

while (true) { 

    println(in.readLine()) 

    // File read. Now blocking. 

} 

Aggiornamento:

Questo file è in realtà una named pipe creata con mkfifo /tmp/mypipe. Ho provato a utilizzare questo con un normale File e ha funzionato bene - tutti i dati visualizzati.

Sto usando una named pipe perché non voglio l'overhead del disco IO.

Answer 1

Se dovessi scommettere, direi che si tratta di un problema di buffering.

Inizialmente pensavo che lo BufferedReader potesse tentare di riempire l'intero buffer, ma sembra che sia felice fintanto che legge qualcosa. Vedi il metodo fill().

Se si utilizza readLine(), c'è anche la domanda se l'input che si ottiene contenga newline.

L'altra cosa che potrebbe accadere, a seconda della quantità di output prodotta dal programma sorgente, è legata al buffering delle pipe. this answer aiuto? È anche possibile provare a terminare il programma sorgente (ad esempio ^C o simile) e quindi verificare se il programma di destinazione stampa nulla.

This pagina suggerisce che il buffer potrebbe essere un problema:

Tuttavia, se si utilizza una scrittura buffer, il buffer non viene reso disponibile al lettore finché il buffer viene svuotato. Questo arrossamento si verifica quando vengono scritti nel buffer più della dimensione massima del buffer (BUFSIZ impostato in stdio.h) o quando la pipe viene chiusa dal writer.