怎么利用Selector的wakeup方法唤醒处于阻塞状态的选择-java教程-PHP中文网

Selector 的 wakeup() 方法用于中断其当前阻塞等待，使线程立即返回并重新轮询；多线程协作中，当其他线程注册新事件而 Selector 正在阻塞时需调用以及时处理；它线程安全，多次调用不累积，仅确保至少一次唤醒。

怎么利用selector的wakeup方法唤醒处于阻塞状态的选择

Selector 的 wakeup() 方法用于中断其当前的阻塞等待（如 select()、select(long) 或 selectNow() 之后的阻塞），让线程立即从阻塞中返回，继续执行后续逻辑。

什么时候需要调用 wakeup()

当另一个线程向 Selector 关联的 Channel 注册了新事件（比如新连接到达、写就绪等），但当前 Selector 正在阻塞等待 I/O 事件时，它不会立刻感知到这个变化。此时调用 wakeup() 可强制它退出阻塞，重新进入轮询逻辑，从而及时处理新增的就绪事件。

常见于多线程协作场景：一个线程负责注册/取消注册 Channel，另一个线程运行 select() 循环
例如，在 NIO 服务端中，主线程监听 Accept，工作线程处理读写；当工作线程完成某个写操作并重新关注 OP_WRITE 时，需唤醒 selector

wakeup() 的基本用法

只需在持有该 Selector 引用的任意线程中调用 selector.wakeup() 即可。它是一个线程安全的方法。

如果 Selector 当前未阻塞，wakeup() 不会生效，也不会报错
如果 Selector 正在阻塞，调用后会立即返回，且下一次 select() 调用将立即返回（返回值为 0 或就绪数量）
注意：多次连续调用 wakeup() 并不会“累积”，只保证至少一次唤醒效果

配合 select() 使用的典型模式

标准 NIO 事件循环中，通常这样组织：

while (running) {
    int n = selector.select(); // 阻塞等待
    if (n == 0) continue;      // 无就绪事件，跳过
<pre class="brush:php;toolbar:false;">Iterator<selectionkey> iter = selector.selectedKeys().iterator();
while (iter.hasNext()) {
    SelectionKey key = iter.next();
    iter.remove();
    if (key.isAcceptable()) { /* 处理新连接 */ }
    if (key.isReadable())  { /* 处理读 */ }
    if (key.isWritable())  { /* 处理写 */ }
}</selectionkey>

}

当其他线程修改了注册状态（比如调用 channel.register(selector, ops)），应在注册后立即调用 selector.wakeup()，确保 select 不会错过这次变更。