java - IOException:读取结束死

Question

什么情况下read end可以死对偶PipedOutputStream和 PipedInputStream ?我没有关闭任何管道。

Answer 1

我遇到了java.io.IOException: Read end dead在我的代码中并找出原因。在下面发布示例代码。如果您运行代码，您将收到“读取结束死机”异常。如果仔细观察，消费者线程从流中读取“hello”并终止；同时生产者 hibernate 2 秒并尝试写入“world”但失败。这里解释了一个相关的问题:http://techtavern.wordpress.com/2008/07/16/whats-this-ioexception-write-end-dead/

class ReadEnd {
public static void main(String[] args) {
    final PipedInputStream in = new PipedInputStream();
    new Thread(new Runnable() { //consumer
        @Override
        public void run() {
            try {
                byte[] tmp = new byte[1024];
                while (in.available() > 0) {         // only once...
                    int i = in.read(tmp, 0, 1024);
                    if (i < 0)
                        break;
                    System.out.print(new String(tmp, 0, i));
                }
            } catch (IOException e) {
                e.printStackTrace();
            } finally {

            }
        }
    }).start();
    PipedOutputStream out = null;
    try {

        out = new PipedOutputStream(in);
        out.write("hello".getBytes());
        Thread.sleep(2 * 1000);
        out.write(" world".getBytes()); //Exception thrown here

    } catch (IOException e) {
        e.printStackTrace();
    } catch (InterruptedException e) {
        e.printStackTrace();
    } finally {
    }
}

}