| 版本 | 内容 | 时间 | | ---- | ---- | ---------------------- | | V1 | 新建 | 2021年12月19日21:53:39 | | V2 | 重构 | 2023年05月18日23:24:27 | ## NioEventLoopGroup 继承关系

NioEventLoopGroup 和 NioEventLoop 继承体系其实大差不差，实现的接口基本上都一样，只是抽象实现类不太一样。NioEventLoopGroup 涉及的相关抽象类如下： - io.netty.util.concurrent.AbstractEventExecutorGroup：提供一些执行任务和生命周期的方法，主要是使用 next() 方法从管理的 EventLoop 中获取其中的一个，去调用对应的 API； - io.netty.util.concurrent.MultithreadEventExecutorGroup：提供管理 EventLoop 的功能（创建容器，就是一个数组）； - io.netty.channel.MultithreadEventLoopGroup：提供向 EventLoop 注册 Channel 的功能（绑定关系）； - io.netty.channel.nio.NioEventLoopGroup：提供创建 EventLoop 的功能； NioEventLoopGroup 比较简单，下面从 NioEventLoopGroup 的创建来分析。 ## NioEventLoopGroup 的创建 ### NioEventLoopGroup 构造函数调用流程从空参构造函数说起： ```java public NioEventLoopGroup() { this(0); } ``` 在 NioEventLoopGroup 类中，最后会调到下面的构造函数 ```java public NioEventLoopGroup(int nThreads, Executor executor, final SelectorProvider selectorProvider,final SelectStrategyFactory selectStrategyFactory) { // 最后一个参数是线程池的拒绝策略 super(nThreads, executor, selectorProvider, selectStrategyFactory, RejectedExecutionHandlers.reject()); } ``` 接着调用父类构造函数，也就是 io.netty.channel.MultithreadEventLoopGroup 的构造函数： ```java protected MultithreadEventLoopGroup(int nThreads, Executor executor, Object... args) { super(nThreads == 0 ? DEFAULT_EVENT_LOOP_THREADS : nThreads, executor, args); } ``` 关于 DEFAULT_EVENT_LOOP_THREADS 的值，默认是 CPU 的个数的两倍，这也就是说**默认情况下，NioEventLoopGroup 会创建 CPU 个数两倍的 EventLoop。** ```java /** * EventLoop的默认线程数量最小值是1 * * 首先去拿 io.netty.eventLoopThreads：环境配置默认线程数 * 假如没有配置 io.netty.eventLoopThreads，默认为当前CPU的核心数的两倍 */ private static final int DEFAULT_EVENT_LOOP_THREADS; static { DEFAULT_EVENT_LOOP_THREADS = Math.max(1, SystemPropertyUtil.getInt( "io.netty.eventLoopThreads", NettyRuntime.availableProcessors() * 2)); if (logger.isDebugEnabled()) { logger.debug("-Dio.netty.eventLoopThreads: {}", DEFAULT_EVENT_LOOP_THREADS); } } ``` 构造函数继续调用父类的构造函数，最后会到 io.netty.util.concurrent.MultithreadEventExecutorGroup，如下： ```java protected MultithreadEventExecutorGroup(int nThreads, Executor executor, EventExecutorChooserFactory chooserFactory, Object... args) { checkPositive(nThreads, "nThreads"); if (executor == null) { // 创建一个Executor执行器对象和线程工厂 executor = new ThreadPerTaskExecutor(newDefaultThreadFactory()); } children = new EventExecutor[nThreads]; // 根据线程数循环创建EventExecutor for (int i = 0; i < nThreads; i ++) { boolean success = false; try { /* * 模板方法模式: 初始化线程组的线程 * NioEventLoopGroup调用时参数为： * args[0]是 SelectorProvider * args[1]是 SelectStrategyFactory * args[2]是线程池拒绝策略 */ children[i] = newChild(executor, args); success = true; } catch (Exception e) { // TODO: Think about if this is a good exception type throw new IllegalStateException("failed to create a child event loop", e); } finally { // 假如初始化关闭失败，需要优雅的关闭，清理资源 if (!success) { for (int j = 0; j < i; j ++) { children[j].shutdownGracefully(); } for (int j = 0; j < i; j ++) { EventExecutor e = children[j]; try { // 当线程没有终止时，等待终止 while (!e.isTerminated()) { e.awaitTermination(Integer.MAX_VALUE, TimeUnit.SECONDS); } } catch (InterruptedException interrupted) { // Let the caller handle the interruption. Thread.currentThread().interrupt(); break; } } } } } // 通过ChooserFactory根据当前Children的数量，构建一个合适的Chooser实例 // Chooser是用来选择NioEventLoop chooser = chooserFactory.newChooser(children); final FutureListener

Netty原理04：线程体系-NioEventLoopGroup.

Dylan Kwok

Netty原理04：线程体系-NioEventLoopGroup