handler 执行中如何换人？

关键代码 io.netty.channel.AbstractChannelHandlerContext#invokeChannelRead()

  1. static void invokeChannelRead(final AbstractChannelHandlerContext next, Object msg) {
  2.     final Object m = next.pipeline.touch(ObjectUtil.checkNotNull(msg, "msg"), next);
  3.     // 下一个 handler 的事件循环是否与当前的事件循环是同一个线程
  4.     EventExecutor executor = next.executor();
  6.     // 是，直接调用
  7.     if (executor.inEventLoop()) {
  8.         next.invokeChannelRead(m);
  9.     } 
  10.     // 不是，将要执行的代码作为任务提交给下一个事件循环处理（换人）
  11.     else {
  12.         executor.execute(new Runnable() {
  13.             @Override
  14.             public void run() {
  15.                 next.invokeChannelRead(m);
  16.             }
  17.         });
  18.     }
  19. }
  • 如果两个 handler 绑定的是同一个线程，那么就直接调用
  • 否则，把要调用的代码封装为一个任务对象，由下一个 handler 的线程来调用