Java NIO Pipe是同一JVM内两线程间单向低开销通信机制，基于内核环形缓冲区，含强绑定的SinkChannel（只写）和SourceChannel（只读），需非阻塞配置、正确缓冲区管理及协作终止约定。
Java NIO 的 Pipe 是专为同一 JVM 内两个线程间单向、低开销数据传输设计的原生机制，不依赖锁、不序列化、零拷贝，底层复用操作系统内核的环形缓冲区（默认约 8 KiB）。它天然适合生产者-消费者模型，但需严格遵循初始化、状态管理与生命周期协同规则。
Pipe 的核心结构必须一次创建、两端绑定
调用 Pipe.open() 会原子性生成一对强绑定通道：
-
Pipe.SinkChannel：只写端，是唯一数据入口，不可读 -
Pipe.SourceChannel：只读端，是唯一数据出口，不可写
两者共享同一内核管道资源，无法反向、不可替换、不能复用。任意一端调用close()，另一端后续 I/O 操作立即抛ClosedChannelException。
写线程：非阻塞写入 + 手动缓冲区控制
必须设为非阻塞，否则线程可能永久挂起：
sinkChannel.configureBlocking(false);
写入前确保 ByteBuffer 处于写模式并已 flip()（position=0，limit=实际数据长度）；每次 write(buffer) 返回实际写入字节数：
立即学习“Java免费学习笔记（深入）”；
- 返回值为 0 → 缓冲区满，需稍后重试（不可忙等，建议
Thread.yield()或交由外部调度） - 小于 buffer 剩余容量 → 调用
buffer.compact()整理未写部分，再继续 - 写完可调用
buffer.clear()复用
⚠️ 常见错误：忘记 flip() 导致 write() 写入 0 字节；关闭 sinkChannel 后仍尝试写入。
pain-to-pip-package
下载
完整流程：Reddit 痛点扫描 → 聚类 → 构建 pip 可安装的 CLI 工具 → 推送到 GitHub。使用此模式已交付 5 款工具，经验证 343 条痛点。
读线程：Selector 监听 + 安全判读返回值
SourceChannel 支持注册到 Selector（SinkChannel 不支持），推荐使用：
sourceChannel.configureBlocking(false); sourceChannel.register(selector, SelectionKey.OP_READ);
就绪后调用 read(buffer)：
- 返回
-1→ 写入端已关闭，应终止读取循环 - 返回
0→ 当前无数据（非错误，非阻塞下的正常现象） - 返回正数 → 实际读取字节数，随后必须
buffer.flip()切换至读模式提取数据，处理完再buffer.clear()
⚠️ 常见错误：未区分 -1 和 0 导致死循环；读取后未 flip() 导致 array() 取出乱码或空内容。
优雅终止与消息边界约定
Pipe 本身不提供关闭通知或消息分界，需协作约定：
- 发送长度为 0 的
ByteBuffer（注意：read()返回 0 表示无数据，不是结束） - 写入特定字节序列（如
"END"）作为终止标记 - 配合
volatile boolean done标志位 +selector.wakeup()触发读线程检查退出条件
避免靠ClosedChannelException控制流程，易引发资源泄漏或状态错乱。
不复杂但容易忽略
