Java NIO的Selector唤醒机制核心是wakeup()方法，它中断阻塞在select()上的线程使其立即返回0，而非通知继续执行；适用于新Channel注册、interestOps修改及外部指令驱动等场景，且多次调用不累积，线程安全但需手动处理假唤醒。
Java NIO 的 Selector 唤醒机制核心就是 wakeup() 方法，它不是“通知线程继续执行”，而是**中断当前阻塞在 select() 上的线程**，让其立即从阻塞中返回，以便及时响应新注册的 Channel、已就绪的 I/O 事件或外部控制逻辑。
唤醒的本质是中断阻塞调用
Selector 的 select()、select(long timeout) 和 selectNow() 行为不同：
– selectNow() 非阻塞，立刻返回；
– select() 和带超时的 select(long) 会阻塞，直到有 Channel 就绪、超时，或被显式唤醒。
而 wakeup() 的作用，就是在任意线程中调用它，使正在阻塞的 select() 调用**立即返回 0（表示本次未轮询到就绪 Channel）**，且不会抛异常——它通过底层操作系统级别的机制（如向内部管道写入一个字节）触发阻塞系统调用返回。
wakeup() 的典型使用场景
它常用于多线程协作中，让 I/O 线程及时感知到主线程或其他工作线程的变更请求：
-
注册新 Channel：当其他线程调用
selector.register(...)时，若 selector 正在 select 阻塞中，需先wakeup()，否则新注册可能延迟到下次 select 才生效； -
取消 Channel 或修改 interestOps：比如关闭连接后调用
selectionKey.cancel()，虽然 cancel 是线程安全的，但若 selector 正阻塞，取消效果要等下一次 select 才被清理，wakeup 可加速清理流程； - 外部指令驱动：如收到 shutdown 信号、配置重载、心跳检测失败等，需让 selector 立即退出阻塞，进入清理或状态切换逻辑。
注意 wakeup() 的几个关键细节
它看似简单，但容易误用：
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
-
多次 wakeup() 不会累积：连续调用多次
wakeup()，只保证下一次select()被唤醒一次；如果 selector 当前未阻塞，wakeup()会“预置唤醒状态”，下次调用select()会立即返回（相当于一次“待生效”的唤醒）； -
唤醒后需手动处理“假唤醒”：select 返回后，必须检查
selectedKeys()是否为空，并重新调用select()（或带超时的版本），否则可能陷入空转循环； -
线程安全，但无需同步调用：
wakeup()是线程安全方法，可由任意线程随时调用，不需要加锁或与 selector 所在线程同步； -
不能替代事件通知逻辑：wakeup 只是“打断阻塞”，不是“传递数据”。真正的新连接、读写事件仍需通过
selectedKeys()遍历获取，不能靠 wakeup 来判断发生了什么。
一个最小可运行示例片段
假设有一个单线程 Selector 循环：
立即学习“Java免费学习笔记（深入）”；
Thread ioThread = new Thread(() -> {
try {
while (!shutdown) {
int n = selector.select(); // 阻塞等待
if (n == 0) continue; // 被 wakeup 或超时，无就绪事件
Iterator<SelectionKey> iter = selector.selectedKeys().iterator();
while (iter.hasNext()) {
SelectionKey key = iter.next();
iter.remove();
if (key.isAcceptable()) handleAccept(key);
else if (key.isReadable()) handleRead(key);
}
}
} catch (IOException e) {
e.printStackTrace();
}
});
ioThread.start();
// 其他线程中：要注册新 Channel
SocketChannel ch = SocketChannel.open();
ch.configureBlocking(false);
ch.register(selector, SelectionKey.OP_READ); // 注册后立即 wakeup
selector.wakeup(); // 确保 select 不会卡住，新 channel 下次能被处理
