pipedreader 和 pipedwriter 是 java 中用于线程间单向字符管道通信的配套流类，需通过 connect() 显式连接，读写操作阻塞同步，缓冲区默认 1024 字符，推荐用 blockingqueue 等并发工具替代。

PipedReader 和 PipedWriter 是 Java 中用于在线程间通过管道传递字符数据的一对配套流类，它们构成一个单向的、基于内存的字符管道：一个线程写入 PipedWriter，另一个线程从关联的 PipedReader 读取，无需文件或网络参与。

核心机制：必须先建立连接

二者不能独立使用，必须通过 connect() 方法绑定。常见写法是构造时直接连接，或显式调用 connect()。未连接就操作会抛出 IOException。

• 推荐方式：在创建后立即连接（避免竞态）
• 错误示例：先启动读线程再连接 → 读线程可能阻塞在 read() 并等待数据，但连接尚未建立，导致死锁风险
• 连接只需一次，且不可重复连接（已连接再调用会抛 IOException）

典型使用模式：生产者-消费者线程协作

一个线程作为“写入端”（生产者），向 PipedWriter 写字符；另一个线程作为“读取端”（消费者），从 PipedReader 读取。读写操作天然同步 —— 若管道缓冲区满（默认大小为 1024 字符），write() 会阻塞；若为空，read() 会阻塞。

Java Maven Secondary Analysis

分析ZIP压缩包或GitLab仓库中的Java Maven项目，确定二次开发范围、类数量、模块分布及生产相关指标。

下载

• 写入端应主动关闭 PipedWriter（调用 close()），这会触发读端的 read() 返回 -1（表示流结束）
• 读端检测到 read() 返回 -1，即可安全退出循环
• 异常处理很重要：任一端异常关闭（如写端抛出 IOException），另一端下次 I/O 操作会收到 IOException

注意缓冲区与阻塞行为

内部缓冲区大小默认为 1024 字符，可通过构造函数指定。它决定了写入端最多能“预存”多少数据而不阻塞。

• 写入少量数据（如几个字符）通常不会阻塞，直接入缓冲区
• 持续写入超过缓冲区容量时，write() 阻塞，直到读端消费部分数据腾出空间
• 读端调用 read(char[] cbuf) 时，若缓冲区为空则阻塞，直到写端写入新数据或流关闭
• 不建议在单线程中同时读写同一管道——会造成自锁（自己等自己）

替代方案与实际建议

虽然功能明确，但 PipedReader/PipedWriter 在现代 Java 开发中较少直接使用，原因包括：

• 线程耦合性强，错误连接易引发死锁
• 异常传播不够直观（如写端异常，读端下一次 read 才感知）
• 更推荐用 java.util.concurrent 中的高阶工具，例如 BlockingQueue<string></string> 或 SynchronousQueue 实现线程间字符/文本传递
• 若需字符流语义，可包装 PipedInputStream/PipedOutputStream 加 InputStreamReader/OutputStreamWriter，但复杂度更高

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南