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

林译川

2026-09-11 • 👁 0人浏览过

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

Iterator iter = selector.selectedKeys().iterator();
while (iter.hasNext()) {
    SelectionKey key = iter.next();
    iter.remove();
    if (key.isAcceptable()) { /* 处理新连接 */ }
    if (key.isReadable())  { /* 处理读 */ }
    if (key.isWritable())  { /* 处理写 */ }
}

} 当其他线程修改了注册状态（比如调用

channel.register(selector, ops)

），应在注册后立即调用

selector.wakeup()

，确保 select 不会错过这次变更。注意事项和常见误区

wakeup()

是轻量级操作，但不应滥用。不要在每次注册/取消注册后都无条件调用——仅当目标 selector 正在阻塞且你希望它尽快响应时才需要调用

wakeup()

后，

select()

返回并不意味着一定有就绪事件，仍要检查

selectedKeys()

是否为空避免在

select()

循环内部频繁调用

wakeup()

，可能导致 CPU 空转或干扰事件调度节奏

相关文章