为什么事件循环使用多个线程？

Question

一直以为异步执行是为了资源的高效利用和线程的安全，今天却遇到了Netty的奇怪行为。

public class Example {
    public static void main(String[] args) throws Exception {
        EventLoopGroup group = new NioEventLoopGroup();
        ServerBootstrap bootstrap = new ServerBootstrap();
        try {
            bootstrap.group(group)
                     .channel(NioServerSocketChannel.class)
                     .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        public void initChannel(SocketChannel channel) {
                            channel.pipeline()
                                   .addLast(new ChannelOutboundHandlerAdapter() {
                                        @Override
                                        public void read(ChannelHandlerContext ctx) {
                                            String id = String.valueOf(Thread.currentThread().getId());
                                            ctx.writeAndFlush(Unpooled.wrappedBuffer(id.getBytes(StandardCharsets.UTF_8)))
                                               .addListener(ChannelFutureListener.CLOSE);
                                            }
                                        });
                        }
                    })
                    .bind("localhost", 1234)
                    .sync()
                    .channel()
                    .closeFuture()
                    .syncUninterruptibly();
        } finally {
            group.shutdownGracefully()
                 .syncUninterruptibly();
        }
    }
}

当我第一次连接时，我得到了 16。然后是 17、18、19 等等。每个连接都是在一个新线程上执行的！为什么？如果它是多线程的，Netty 的意义何在？

Answer 1

NioEventLoopGroup 使用工作线程来利用多个 CPU 内核。根据the no-argument constructor javadoc：

NioEventLoopGroup()

使用默认线程数、默认 ThreadFactory 和 SelectorProvider.provider() 返回的 SelectorProvider 创建一个新实例。

根据MultithreadEventLoopGroup 的默认线程数将是可用处理器数量的两倍：

DEFAULT_EVENT_LOOP_THREADS = Math.max(1, SystemPropertyUtil.getInt(
            "io.netty.eventLoopThreads", NettyRuntime.availableProcessors() * 2));

通常这应该足以使 CPU 饱和而不会创建大量线程。产生的线程太少，您将无法获得完整的 CPU 利用率。生成太多，您将浪费大量时间在它们之间进行上下文切换。