java中通过继承thread类并配合pipedinputstream/pipedoutputstream实现线程通信，需先调用connect()建立管道连接，写入端向pipedoutputstream写数据并close()通知结束，读取端从pipedinputstream阻塞读取直至返回-1；字符流可用pipedreader/pipedwriter替代，用法类似。

Java中利用继承Thread类配合管道流（PipedInputStream和PipedOutputStream）实现线程通信，核心在于：一个线程作为“写入端”向PipedOutputStream写数据，另一个线程作为“读取端”从关联的PipedInputStream读数据，二者通过connect()建立管道连接。这种方式天然适用于生产者-消费者模型，无需共享变量或外部文件。

必须先建立连接才能通信

管道流不是独立工作的——PipedInputStream和PipedOutputStream必须显式连接，否则写入时会抛出IOException: Pipe not connected。连接只能做一次，且应在启动线程前完成：

• 推荐写法：outputStream.connect(inputStream)
• 也可以在构造PipedInputStream时传入PipedOutputStream（如new PipedInputStream(out)），效果等价
• 切忌在两个线程中分别构造再尝试连接——容易因时序问题导致IOException

写入线程继承Thread并操作PipedOutputStream

写入线程通常重写run()方法，将数据写入PipedOutputStream。注意关闭流以通知读端结束，并捕获IOException：

JavaStoryDevelop

你接手一个需求时，是不是经常这样："改一个小字段 → 结果把不相关的代码也改了"、"需求说得很模糊 → 做着做着发现跑偏了"、"数据库加个字段 → 上线才发现漏了数据兼容"、"做了个新功能 → 一个月后自己都忘了当时怎么设计的"、"写到一半被中断 → 再回来不知道从哪继续"；这个 Skill 就是专门解决这些问题的。 它会自动探测你的项目环境（JDK、Spring Boot、ORM、数据库、前端框架），记在

下载

• 使用out.write(byte[])或out.write(int)发送字节数据
• 写完调用out.close()，这会触发读端read()返回-1（表示流结束）
• 避免在循环中频繁创建新字节数组；可复用缓冲区提升效率

读取线程继承Thread并操作PipedInputStream

读取线程从PipedInputStream中阻塞读取，直到有数据到达或流关闭：

• 用input.read(byte[])批量读取更高效；单字节读取（input.read()）适合简单场景
• 读到-1说明写端已关闭，应退出循环并调用input.close()
• 读取过程自动阻塞——无数据时线程挂起，有数据立即唤醒，无需手动wait/notify

字符流可用PipedReader/PipedWriter替代

如果传输的是文本数据，直接用字符流更自然，避免手动处理编码：

• PipedWriter对应写入端，PipedReader对应读取端
• 同样需要connect()，用法与字节流一致
• 写入用writer.write(String)，读取用reader.read(char[])，自动处理字符编码

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