优雅关闭 reactor 线程池需先停止接收任务、再等待已提交任务完成、最后释放资源；核心包括：用 volatile 标志+selector.wakeup() 退出事件循环，主动取消并关闭 channel，按序协调线程池与 reactor 生命周期，安全关闭 selector，并封装 shutdown() 方法。
优雅关闭 Reactor 线程池的核心是：先停止接收新任务、再等待已提交任务完成、最后释放资源，同时避免 NIO 关键组件（如 Selector、Channel）在关闭过程中被并发操作导致异常。
确保 Reactor 线程主动退出事件循环
Reactor 线程通常运行在 while (selector.select() > 0) { ... } 循环中。直接中断线程不可靠，应配合 selector.wakeup() 和退出标志位：
- 定义 volatile 布尔变量（如
running = true），在循环条件中检查：while (running && selector.select() >= 0) - 关闭时先置
running = false，再调用selector.wakeup()唤醒阻塞的select() - 避免使用
Thread.interrupt()—— 它可能触发未预期的ClosedSelectorException或掩盖真实问题
安全注销 Channel 并关闭底层资源
不能等线程退出后再逐个关 Channel，否则可能漏处理或引发 CancelledKeyException。应在关闭流程中主动清理：
- 遍历
selector.keys()，对每个SelectionKey调用key.cancel() - 调用
channel.close()（如SocketChannel、ServerSocketChannel），注意捕获IOException但不抛出 - 确保
channel.close()在当前 Reactor 线程执行 —— 避免跨线程关闭导致状态不一致
协调线程池与 Reactor 生命周期
若使用 ExecutorService 管理多个 Reactor 线程（如每个线程绑定一个 Selector），需按顺序关闭：
- 向每个 Reactor 线程发送退出信号（通过共享标志 +
wakeup） - 调用
executor.shutdown()，再用awaitTermination()等待所有 Reactor 线程自然退出 - 超时后可调用
shutdownNow()强制中断 —— 仅作为兜底，此时应确保资源清理逻辑（如 finally 中的 channel 关闭）已覆盖
补充：关闭 Selector 本身
Selector.close() 是线程安全的，但必须确保没有其他线程正在调用其方法（如 select()、register()）：
- 在 Reactor 线程确认退出循环后、线程真正终止前调用
selector.close() - 关闭后若仍有线程尝试操作该 selector，会抛
ClosedSelectorException—— 这说明生命周期管理有竞态，需回查退出逻辑 - 不必显式清空
keys()或selectedKeys()，close()会自动取消全部 key 并释放底层文件描述符
不复杂但容易忽略的是：所有关闭动作最好封装在 Reactor 实例的 shutdown() 方法中，并提供同步阻塞版本（如 shutdown(long timeout, TimeUnit unit)）供上层调用。这样既保证内聚，也方便单元测试和容器化生命周期管理。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
