java中pipedinputstream实现多线程通信需满足三前提：单生产者单消费者、构造时绑定连接、读线程先启动并阻塞就绪；否则易阻塞、异常或死锁。
Java 中用 PipedInputStream 实现多线程通信，核心是让一个线程往 PipedOutputStream 写数据，另一个线程从配套的 PipedInputStream 读数据，两者通过内存缓冲区直连，不经过文件或网络，属于轻量级线程间字节流通道。
但要注意：它不是“开箱即用”的低延迟方案，必须按规范初始化、配对使用，否则容易阻塞、抛异常甚至死锁。
必须满足的三个前提条件
单生产者 + 单消费者
一个PipedOutputStream只能连一个PipedInputStream；多个线程同时写入会触发IOException: Write end dead。-
连接必须在 I/O 操作前完成，且只能靠构造绑定
❌ 错误写法：先new PipedInputStream()和new PipedOutputStream()，再各自线程里调connect()—— 存在竞态，写端可能在读端 connect 前就 write，直接报Pipe not connected。
✅ 正确写法：用构造函数绑定，例如PipedInputStream pis = new PipedInputStream(); PipedOutputStream pos = new PipedOutputStream(pis); // 自动 connect // 或 PipedOutputStream pos = new PipedOutputStream(); PipedInputStream pis = new PipedInputStream(pos); // 同样自动 connect
读线程必须先启动并进入阻塞读状态
写线程第一次write()时，若读端还没开始read()（甚至没调available()），可能因缓冲区为空而卡住。
建议读线程一启动就调一次read()（哪怕只读一个字节），确保内部状态就绪。
典型安全用法示例
// 1. 构造并绑定
PipedInputStream pis = new PipedInputStream(128); // 显式设缓冲区大小
PipedOutputStream pos = new PipedOutputStream(pis);
// 2. 启动读线程（先启）
Thread reader = new Thread(() -> {
try {
byte[] buf = new byte[1024];
int n;
while ((n = pis.read(buf)) != -1) {
System.out.write(buf, 0, n);
}
System.out.println("读端收到 EOF");
} catch (IOException e) {
if (!e.getMessage().contains("Write end dead")) {
e.printStackTrace();
}
} finally {
try { pis.close(); } catch (IOException ignored) {}
}
});
reader.start();
// 3. 启动写线程（后启）
Thread writer = new Thread(() -> {
try {
pos.write("Hello from pipe!".getBytes(StandardCharsets.UTF_8));
pos.close(); // 关键：主动 close，通知读端结束
} catch (IOException e) {
e.printStackTrace();
}
});
writer.start();
⚠️ 注意：
pis.read()返回-1表示写端已close()，这是正常结束信号；若写端异常崩溃未 close，读端会一直阻塞——所以业务逻辑中建议加超时探测或配合available()做非阻塞轮询。
避免踩坑的关键细节
不要混用字节流和字符流
PipedOutputStream+PipedInputStream是字节流；PipedWriter+PipedReader是字符流。二者不能交叉使用，否则抛IOException。缓冲区大小影响延迟与吞吐
默认 1024 字节：小数据写入易阻塞（等填满才唤醒读端）；设为1或8可降低延迟，但频繁小写仍慢——推荐批量写：pos.write(byte[], off, len)，避免逐字节write(int)。关闭顺序很重要
写端close()→ 读端read()返回-1→ 读端自己close()。
若读端不检查-1就继续循环，会空转；若写端不 close，读端永远等不到 EOF。无法中断阻塞读
pis.read()不响应Thread.interrupt()，也没有超时重载方法。如需可控等待，可用pis.available() > 0判断是否有数据，再决定是否read()，中间穿插sleep(1)。
不复杂但容易忽略。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
