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

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 内核。根据无参数构造函数 javadoc：

NioEventLoopGroup()

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

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

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

通常，这应该足以在不创建大量线程的情况下使 CPU 饱和。生成的线程太少，您将无法充分利用 CPU。生成太多，您将浪费大量时间在它们之间进行上下文切换。