PipedInputStream - Wie zu vermeiden "java.io.IOException: Rohr gebrochen"

Question

Ich habe zwei Threads. Einer von ihnen schreibt in PipedOutputStream, ein anderer liest aus dem entsprechenden PipedInputStream. Hintergrund ist, dass ein Thread einige Daten vom Remote-Server herunterlädt und sie über Pipestreams zu mehreren anderen Threads multiplext.

Das Problem ist, dass manchmal (vor allem, wenn das Herunterladen großer (> 50MB) Dateien) Ich java.io.IOException erhalten: Rohr gebrochen, wenn sie von PipedInputStream zu lesen versuchen.
Javadoc sagt, dass A pipe is said to be broken if a thread that was providing data bytes to the connected piped output stream is no longer alive.
Es ist wahr, mein Schreiben Thread wirklich stirbt nach dem Schreiben aller seiner Daten zu PipedOutputStream.

Irgendwelche Lösungen? Wie kann ich verhindern, dass PipedInputStream diese Ausnahme auslöst? Ich möchte in der Lage sein, alle Daten zu lesen, die in PipedOutputStream geschrieben wurden, selbst wenn der Schreib-Thread seine Arbeit beendet hat. (Wenn jemand weiß, wie man den Thread am Leben hält, bis alle Daten gelesen sind, ist diese Lösung ebenfalls akzeptabel).

Answer 1

Verwenden Sie java.util.concurrent.CountDownLatch, und beenden Sie nicht den ersten Thread, bevor der zweite Thread signalisiert hat, dass er die Pipeline gelesen hat.

Update: quick and dirty Code mein Kommentar unten

final PipedInputStream pin = getInputStream(); 
    final PipedOutputStream pout = getOutputStream(); 

    final CountDownLatch latch = new CountDownLatch(1); 

    InputStream in = new InputStream() { 

     @Override 
     public int read() throws IOException { 
      return pin.read(); 
     } 

     @Override 
     public void close() throws IOException { 
      super.close(); 
      latch.countDown(); 
     } 
    }; 


    OutputStream out = new OutputStream(){ 

     @Override 
     public void write(int b) throws IOException { 
      pout.write(b); 
     } 

     @Override 
     public void close() throws IOException { 
      while(latch.getCount()!=0) { 
       try { 
        latch.await(); 
       } catch (InterruptedException e) { 
        //too bad 
       } 
      } 
      super.close(); 
     } 
    }; 

    //give the streams to your threads, they don't know a latch ever existed 
    threadOne.feed(in); 
    threadTwo.feed(out); 

Answer 2

PipedInputStream und PipedOutputStream sind gebrochen zu veranschaulichen (in Bezug auf Threading). Sie gehen davon aus, dass jede Instanz an einen bestimmten Thread gebunden ist. Das ist bizarr. Ich empfehle Ihnen, Ihre eigene (oder zumindest eine andere) Implementierung zu verwenden.

Answer 3

Schließen Sie Ihre PipedOutputStream, wenn der Thread, der sie verwendet, endet? Sie müssen dies tun, damit die darin enthaltenen Bytes zu den entsprechenden PipedInputStream gespült werden.