Ist Java FileInputStream Sperrdatei zum Schreiben

Question

Ich erstelle eine schnelle Brücke zwischen zwei separaten Programmen.

Ein Programm schreibt in eine Datei, während mein Programm gleichzeitig davon liest.

Es scheint, dass, sobald ich den ersten Lesevorgang anrufe, das Schreiben vollständig blockiert ist.

Warum tritt dies auf und was ist die Problemumgehung?

// 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. 

} 

Update:

Diese Datei ist eigentlich ein Named Pipe mit mkfifo /tmp/mypipe erstellt. Ich versuchte es mit einem normalen File und es funktionierte gut - alle Daten angezeigt.

Ich benutze eine Named Pipe, weil ich nicht die Festplatte IO Overhead will.

Answer 1

Wenn ich wetten müsste, würde ich sagen, dass es ein Pufferproblem ist.

Anfangs dachte ich, dass BufferedReader versuchen könnte, seinen gesamten Puffer zu füllen, aber es sieht aus wie es glücklich ist, solange es etwas liest. Siehe die fill() Methode.

Wenn Sie readLine() verwenden, gibt es auch die Frage, ob die Eingabe, die Sie erhalten, Zeilenumbrüche enthält.

Die andere Sache, die passieren könnte, abhängig davon, wie viel Ausgang das Quellprogramm erzeugt, ist mit Pipe-Pufferung zu tun. Würde this answer helfen? Sie können auch versuchen, das Quellprogramm zu beenden (z. B. ^C oder so) und dann sehen, ob das Zielprogramm etwas ausgibt.

This Seite schlägt vor, dass Pufferung ein Problem sein könnte:

Wenn jedoch eine gepufferte Schreib verwendet wird, wird der Puffer nicht den Leser zur Verfügung gestellt, bis der Puffer geleert wird. Dieses Löschen findet statt, wenn mehr Daten in den Puffer geschrieben werden als die maximale Puffergröße (BUFSIZ in stdio.h), oder wenn die Pipe vom Writer geschlossen wird.