PipedInputStream - 如何避免"java.io.IOException:Pipe broken"

Thread writerThread = new Thread(new Runnable() {
    @Override
    public void run() {
        // 写入数据的代码
    }
});
writerThread.start();

// 读取数据的代码

writerThread.join(); // 等待写入线程结束

PipedOutputStream outputStream = new PipedOutputStream();
PipedInputStream inputStream = new PipedInputStream(outputStream);

try (PipedInputStream inputStream = new PipedInputStream();
     PipedOutputStream outputStream = new PipedOutputStream(inputStream)) {
    // 写入数据的代码
    // 读取数据的代码
} catch (IOException e) {
    e.printStackTrace();
}

try {
    // 读取数据的代码
} catch (IOException e) {
    // 如果是"Pipe broken"异常，则不再重试
    if (!e.getMessage().equals("Pipe broken")) {
        // 重新尝试读取数据的代码
    }
}