java - IOException：读取结束已死

Question

什么情况下读完会死在夫妻PipedOutputStream和PipedInputStream？我没有关闭任何管道。

Answer 1

我在我的代码中遇到java.io.IOException: Read end dead并找出了原因。在下面发布示例代码。如果您运行代码，您将收到“Read end dead”异常。如果仔细观察，消费者线程会从流中读取“hello”并终止；同时生产者休眠 2 秒并尝试写入“世界”但失败。此处解释了一个相关问题：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 {
    }
}

}