PipedInputStream 高速字节传输的关键在于结构合理、阻塞可控、缓冲适配、关闭有序；需构造时绑定、读写线程分离、批量写入、按场景调优缓冲（1024–16384B）、close 后 read 返回 -1 表示正常 EOF。
用 PipedInputStream 实现不同工作线程间的高速字节传输，关键不在“堆参数”，而在于结构合理、阻塞可控、缓冲适配、关闭有序。它不是万能队列替代品，而是专为低延迟、单向、内存直通式字节流设计的轻量通道。
绑定必须早且稳：避免连接竞态
两个流必须构成封闭管道，推荐用构造函数直接关联，不依赖 connect() 手动调用：
-
✅ 推荐写法：
PipedInputStream pis = new PipedInputStream(8192);+PipedOutputStream pos = new PipedOutputStream(pis);—— 构造即绑定，线程安全，无竞态风险 -
❌ 避免写法：
PipedInputStream pis = new PipedInputStream(); PipedOutputStream pos = new PipedOutputStream(); pis.connect(pos);—— 若写线程在 connect 前就调用 write()，会抛IOException: Pipe not connected
读写必须分离：死锁只因同线程操作
绝对禁止在同一个线程中既 write 又 read，否则立即死锁：
- 写线程只负责
pos.write(byte[], off, len)（批量写）或pos.close()，不碰 pis - 读线程只负责
pis.read(byte[])循环消费，不碰 pos - 不要用
write(int b)逐字节写——加锁频繁、唤醒开销大；改用批量写，吞吐提升 3–5 倍
缓冲要调得准：小不是快，满才生效
默认 1024 字节缓冲区适合通用场景，但“高速”需按数据节奏调优：
- 高频小包（如传感器每 10ms 上报 64B）：用 1024–4096 字节缓冲，平衡延迟与唤醒频率
- 中等批量流（如日志块 2–8KB）：设为 8192 或 16384，减少 write() 阻塞次数，实测耗时下降约 35%
- 缓冲不能设为 0；也不建议超 64KB——过大易导致 GC 压力和内存碎片
结束信号要主动识别：-1 不是异常，是协议
写端调用 pos.close() 后，读端下一次 read() 返回 -1，表示正常 EOF：
- 读线程必须检查
if (n == -1) break;，而不是捕获 IOException 当作结束依据 - 若需区分“优雅关闭”和“崩溃中断”，可在 close 前写一个约定标记字节（如
pos.write(0xFF)），读端收到即走错误路径 - 读到 -1 后应主动
pis.close()，释放底层循环缓冲数组，避免内存泄漏
