PipedReader 和 PipedWriter 是 Java 中用于线程间单向字符管道通信的配套流类，需通过 connect() 显式连接，读写操作阻塞同步，缓冲区默认 1024 字符，推荐用 BlockingQueue 等并发工具替代。
PipedReader 和 PipedWriter 是 Java 中用于在线程间通过管道传递字符数据的一对配套流类，它们构成一个单向的、基于内存的字符管道：一个线程写入 PipedWriter，另一个线程从关联的 PipedReader 读取，无需文件或网络参与。
核心机制：必须先建立连接
二者不能独立使用，必须通过 connect() 方法绑定。常见写法是构造时直接连接，或显式调用 connect()。未连接就操作会抛出 IOException。
- 推荐方式：在创建后立即连接（避免竞态）
- 错误示例：先启动读线程再连接 → 读线程可能阻塞在
read()并等待数据，但连接尚未建立，导致死锁风险 - 连接只需一次，且不可重复连接（已连接再调用会抛
IOException）
典型使用模式：生产者-消费者线程协作
一个线程作为“写入端”（生产者），向 PipedWriter 写字符；另一个线程作为“读取端”（消费者），从 PipedReader 读取。读写操作天然同步 —— 若管道缓冲区满（默认大小为 1024 字符），write() 会阻塞；若为空，read() 会阻塞。
- 写入端应主动关闭
PipedWriter（调用close()），这会触发读端的read()返回 -1（表示流结束） - 读端检测到
read()返回 -1，即可安全退出循环 - 异常处理很重要：任一端异常关闭（如写端抛出 IOException），另一端下次 I/O 操作会收到
IOException
注意缓冲区与阻塞行为
内部缓冲区大小默认为 1024 字符，可通过构造函数指定。它决定了写入端最多能“预存”多少数据而不阻塞。
立即学习“Java免费学习笔记（深入）”；
- 写入少量数据（如几个字符）通常不会阻塞，直接入缓冲区
- 持续写入超过缓冲区容量时，
write()阻塞，直到读端消费部分数据腾出空间 - 读端调用
read(char[] cbuf)时，若缓冲区为空则阻塞，直到写端写入新数据或流关闭 - 不建议在单线程中同时读写同一管道——会造成自锁（自己等自己）
替代方案与实际建议
虽然功能明确，但 PipedReader/PipedWriter 在现代 Java 开发中较少直接使用，原因包括：
- 线程耦合性强，错误连接易引发死锁
- 异常传播不够直观（如写端异常，读端下一次 read 才感知）
- 更推荐用
java.util.concurrent中的高阶工具，例如BlockingQueue<String>或SynchronousQueue实现线程间字符/文本传递 - 若需字符流语义，可包装
PipedInputStream/PipedOutputStream加InputStreamReader/OutputStreamWriter，但复杂度更高
