动易网站 教程,百度链接提交地址,网页制作下载什么软件,logo生成器免费下载文章目录 概述类继承关系源码分析小结 概述 EventLoopGroup bossGroup new NioEventLoopGroup(1);
EventLoopGroup workerGroup new NioEventLoopGroup();这段代码是在使用Netty框架时常见的用法#xff0c;用于创建两个不同的EventLoopGroup实例#xff0c;一个用于处理连… 文章目录 概述类继承关系源码分析小结 概述 EventLoopGroup bossGroup new NioEventLoopGroup(1);
EventLoopGroup workerGroup new NioEventLoopGroup();这段代码是在使用Netty框架时常见的用法用于创建两个不同的EventLoopGroup实例一个用于处理连接请求通常称为bossGroup另一个用于处理连接后的数据流通常称为workerGroup。
NioEventLoopGroup是Netty中用于处理NIO事件的EventLoopGroup的实现之一。在Netty中事件循环EventLoop是Netty的核心负责处理各种事件比如接收连接、读取数据、写入数据等。
其主要功能和构造函数参数的含义 构造函数参数说明 第一个构造函数参数表示创建的EventLoop的数量。对于bossGroup它通常设置为1因为它主要用于处理连接请求而不是处理连接后的数据流。对于workerGroup通常不设置数量因为它会根据系统的CPU核心数量自动创建相应数量的EventLoop。 在构造函数中NioEventLoopGroup会创建一组NioEventLoop实例。NioEventLoop是Netty中基于NIO的事件循环实现它负责处理事件的派发和执行。 在NioEventLoopGroup的实现中通常会创建一个或多个线程来执行事件循环中的任务。这些线程会不断地轮询注册在其上的Channel处理各种事件。 对于bossGroup和workerGroup它们分别负责处理不同类型的事件bossGroup主要处理连接请求而workerGroup主要处理连接后的数据流。
总的来说NioEventLoopGroup的源码实现涉及到底层的NIO编程和多线程处理它提供了一个高效的事件处理机制使得Netty能够处理大量并发连接和数据流。 类继承关系 源码分析
EventLoopGroup bossGroup new NioEventLoopGroup(1);
EventLoopGroup workerGroup new NioEventLoopGroup();NioEventLoopGroup类的构造函数用于创建一个新的NioEventLoopGroup实例。 public NioEventLoopGroup(int nThreads) {this(nThreads, (Executor) null);
}这个构造函数接受一个参数nThreads表示要创建的EventLoop的数量。然后调用了另一个构造函数this(nThreads, (Executor) null)。
在这个构造函数中nThreads表示要创建的EventLoop的数量通常情况下会根据CPU核心数来确定。参数(Executor) null表示没有指定额外的Executor这意味着EventLoopGroup会使用默认的线程工厂来创建线程。
总的来说这个构造函数的作用是根据指定的线程数量创建一个新的NioEventLoopGroup实例并使用默认的线程工厂来创建线程。 继续 public NioEventLoopGroup(int nThreads, Executor executor) {this(nThreads, executor, SelectorProvider.provider());}这段代码是NioEventLoopGroup类的构造函数的另一个重载版本接受三个参数nThreads、executor和SelectorProvider.provider()。
这个构造函数接受三个参数
nThreads表示要创建的EventLoop的数量。executor表示一个可选的外部Executor用于执行EventLoop中的任务。如果传入null则会使用默认的线程工厂来创建线程。SelectorProvider.provider()返回一个默认的SelectorProvider用于创建Selector实例。
然后这个构造函数调用了另一个构造函数this(nThreads, executor, SelectorProvider.provider())将这三个参数传递给它。
这个构造函数的作用是根据指定的线程数量创建一个新的NioEventLoopGroup实例并允许传入一个可选的Executor以及一个SelectorProvider用于创建Selector实例。 继续 public NioEventLoopGroup(int nThreads, Executor executor, final SelectorProvider selectorProvider) {this(nThreads, executor, selectorProvider, DefaultSelectStrategyFactory.INSTANCE);
}这段代码是NioEventLoopGroup类的构造函数的另一个重载版本接受四个参数nThreads、executor、selectorProvider和DefaultSelectStrategyFactory.INSTANCE。
这个构造函数接受四个参数
nThreads表示要创建的EventLoop的数量。executor表示一个可选的外部Executor用于执行EventLoop中的任务。如果传入null则会使用默认的线程工厂来创建线程。selectorProvider表示一个SelectorProvider用于创建Selector实例。DefaultSelectStrategyFactory.INSTANCE是一个默认的Select策略工厂实例用于创建Select策略。
然后这个构造函数调用了另一个构造函数this(nThreads, executor, selectorProvider, DefaultSelectStrategyFactory.INSTANCE)将这四个参数传递给它。
这个构造函数的作用是根据指定的线程数量创建一个新的NioEventLoopGroup实例并允许传入一个可选的Executor、SelectorProvider以及一个默认的Select策略工厂实例。 继续 public NioEventLoopGroup(int nThreads, Executor executor, final SelectorProvider selectorProvider,final SelectStrategyFactory selectStrategyFactory) {super(nThreads, executor, selectorProvider, selectStrategyFactory, RejectedExecutionHandlers.reject());
}这段代码是NioEventLoopGroup类的构造函数的最终版本接受五个参数nThreads、executor、selectorProvider、selectStrategyFactory和RejectedExecutionHandlers.reject()。
这个构造函数调用了父类构造函数super()传递了五个参数
nThreads表示要创建的EventLoop的数量。executor表示一个可选的外部Executor用于执行EventLoop中的任务。如果传入null则会使用默认的线程工厂来创建线程。selectorProvider表示一个SelectorProvider用于创建Selector实例。selectStrategyFactory表示一个Select策略工厂用于创建Select策略。RejectedExecutionHandlers.reject()是一个拒绝执行处理器用于处理任务提交被拒绝的情况。
这个构造函数的作用是根据指定的参数创建一个新的NioEventLoopGroup实例并设置Executor、SelectorProvider、Select策略工厂和拒绝执行处理器。 继续 protected MultithreadEventLoopGroup(int nThreads, Executor executor, Object... args) {super(nThreads 0 ? DEFAULT_EVENT_LOOP_THREADS : nThreads, executor, args);
}这段代码是MultithreadEventLoopGroup类的构造函数它是MultithreadEventExecutorGroup类的子类。让我们详细解释这段代码的实现
这个构造函数通过调用父类构造函数super()来创建一个新的MultithreadEventLoopGroup实例它接受三个参数
nThreads表示要创建的EventLoop的数量如果传入的值为0则使用默认值DEFAULT_EVENT_LOOP_THREADS。executor表示一个可选的外部Executor用于执行EventLoop中的任务。如果传入null则会使用默认的线程工厂来创建线程。args表示可变参数用于传递额外的参数给父类构造函数。
在这个构造函数中首先通过三元运算符判断nThreads是否为0如果是则使用默认值DEFAULT_EVENT_LOOP_THREADS否则使用传入的值。然后调用父类构造函数传递这三个参数。 DEFAULT_EVENT_LOOP_THREADS
private static final int DEFAULT_EVENT_LOOP_THREADS;static {// 获取系统属性io.netty.eventLoopThreads如果未设置则使用默认值为可用处理器数的两倍DEFAULT_EVENT_LOOP_THREADS Math.max(1, SystemPropertyUtil.getInt(io.netty.eventLoopThreads, NettyRuntime.availableProcessors() * 2));// 如果日志级别为DEBUG则输出默认的EventLoop线程数if (logger.isDebugEnabled()) {logger.debug(-Dio.netty.eventLoopThreads: {}, DEFAULT_EVENT_LOOP_THREADS);}
}这段代码是一个静态代码块用于初始化DEFAULT_EVENT_LOOP_THREADS这个静态常量。
这个静态代码块主要做了两件事情
通过SystemPropertyUtil.getInt()方法获取系统属性io.netty.eventLoopThreads的值如果未设置则使用默认值为可用处理器数的两倍。如果日志级别为DEBUG则通过日志记录框架输出默认的EventLoop线程数。
这个静态代码块的作用是在类加载时初始化DEFAULT_EVENT_LOOP_THREADS这个静态常量并根据系统属性设置默认的EventLoop线程数。
总的来说这个构造函数的作用是根据指定的参数创建一个新的MultithreadEventLoopGroup实例并设置EventLoop的数量和Executor。 继续 protected MultithreadEventExecutorGroup(int nThreads, Executor executor, Object... args) {this(nThreads, executor, DefaultEventExecutorChooserFactory.INSTANCE, args);
}这段代码是MultithreadEventExecutorGroup类的受保护构造函数用于创建一个新的MultithreadEventExecutorGroup实例。
这个构造函数接受三个参数
nThreads表示要创建的线程数。executor表示一个可选的外部Executor用于执行任务。如果传入null则会使用默认的线程工厂来创建线程。args表示可变参数用于传递额外的参数给子类的newChild()方法。
在这个构造函数中调用了另一个构造函数this(nThreads, executor, DefaultEventExecutorChooserFactory.INSTANCE, args)将这三个参数传递给它并传递了一个默认的EventExecutor选择器工厂实例DefaultEventExecutorChooserFactory.INSTANCE。
这个构造函数的作用是根据指定的参数创建一个新的MultithreadEventExecutorGroup实例并使用默认的EventExecutor选择器工厂。 继续 这段代码是MultithreadEventExecutorGroup类的受保护构造函数的具体实现用于创建一个新的MultithreadEventExecutorGroup实例。
请看注释
protected MultithreadEventExecutorGroup(int nThreads, Executor executor,EventExecutorChooserFactory chooserFactory, Object... args) {if (nThreads 0) {throw new IllegalArgumentException(String.format(nThreads: %d (expected: 0), nThreads));}// 如果传入的Executor为null则使用默认的ThreadPerTaskExecutor并创建一个新的线程工厂if (executor null) {executor new ThreadPerTaskExecutor(newDefaultThreadFactory());}// 初始化children数组用于存储创建的EventExecutor实例children new EventExecutor[nThreads];// 循环创建nThreads个EventExecutor实例for (int i 0; i nThreads; i ) {boolean success false;try {// 调用newChild方法创建EventExecutor实例并将其存储到children数组中children[i] newChild(executor, args);success true;} catch (Exception e) {// 在创建EventExecutor实例时发生异常抛出IllegalStateException异常throw new IllegalStateException(failed to create a child event loop, e);} finally {// 如果创建EventExecutor实例失败则关闭已创建的实例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) {// 如果等待过程中发生中断异常则将中断信号重新设置Thread.currentThread().interrupt();break;}}}}}// 根据chooserFactory创建一个EventExecutor选择器chooser chooserFactory.newChooser(children);// 创建一个监听器用于监听所有EventExecutor实例的终止事件final FutureListenerObject terminationListener new FutureListenerObject() {Overridepublic void operationComplete(FutureObject future) throws Exception {if (terminatedChildren.incrementAndGet() children.length) {terminationFuture.setSuccess(null);}}};// 添加终止事件监听器到每个EventExecutor实例的terminationFuture上for (EventExecutor e: children) {e.terminationFuture().addListener(terminationListener);}// 将children数组转换为不可修改的集合SetEventExecutor childrenSet new LinkedHashSetEventExecutor(children.length);Collections.addAll(childrenSet, children);readonlyChildren Collections.unmodifiableSet(childrenSet);
}这个构造函数的作用是根据指定的参数创建一个新的MultithreadEventExecutorGroup实例并初始化一组EventExecutor实例。
如果创建EventExecutor实例失败则会关闭已创建的实例并等待它们终止。
最后创建一个监听器用于监听所有EventExecutor实例的终止事件并将children数组转换为不可修改的集合。 重点关注 children[i] newChild(executor, args); Overrideprotected EventLoop newChild(Executor executor, Object... args) throws Exception {return new NioEventLoop(this, executor, (SelectorProvider) args[0],((SelectStrategyFactory) args[1]).newSelectStrategy(), (RejectedExecutionHandler) args[2]);}这段代码是MultithreadEventLoopGroup类中的一个重要方法newChild()的实现它用于创建新的EventLoop实例。
Override
protected EventLoop newChild(Executor executor, Object... args) throws Exception {// 从参数数组中获取需要的参数包括SelectorProvider、SelectStrategyFactory和RejectedExecutionHandlerSelectorProvider selectorProvider (SelectorProvider) args[0];SelectStrategyFactory selectStrategyFactory (SelectStrategyFactory) args[1];RejectedExecutionHandler rejectedExecutionHandler (RejectedExecutionHandler) args[2];// 调用NioEventLoop的构造函数创建一个新的NioEventLoop实例并返回return new NioEventLoop(this, executor, selectorProvider, selectStrategyFactory.newSelectStrategy(), rejectedExecutionHandler);
}这个方法的作用是根据给定的参数创建一个新的EventLoop实例。它首先从参数数组中获取所需的参数包括SelectorProvider、SelectStrategyFactory和RejectedExecutionHandler然后调用NioEventLoop的构造函数创建一个新的NioEventLoop实例并将这些参数传递给它。
总的来说newChild()方法的作用是创建一个新的EventLoop实例并返回该实例。在MultithreadEventLoopGroup中每个EventLoop实例都负责处理一部分任务。 new NioEventLoop(this, executor, selectorProvider, selectStrategyFactory.newSelectStrategy(), rejectedExecutionHandler) 这段代码是NioEventLoop类的构造函数用于创建一个新的NioEventLoop实例。
让我们逐步解释这段代码的实现
NioEventLoop(NioEventLoopGroup parent, Executor executor, SelectorProvider selectorProvider,SelectStrategy strategy, RejectedExecutionHandler rejectedExecutionHandler) {// 调用父类SingleThreadEventExecutor的构造函数创建一个新的实例super(parent, executor, false, DEFAULT_MAX_PENDING_TASKS, rejectedExecutionHandler);// 检查selectorProvider和selectStrategy是否为null如果是则抛出NullPointerExceptionif (selectorProvider null) {throw new NullPointerException(selectorProvider);}if (strategy null) {throw new NullPointerException(selectStrategy);}// 初始化成员变量provider为传入的selectorProviderprovider selectorProvider;// 调用openSelector()方法打开一个新的Selector并将返回的SelectorTuple中的selector和unwrappedSelector分别赋值给成员变量selector和unwrappedSelectorfinal SelectorTuple selectorTuple openSelector();selector selectorTuple.selector;unwrappedSelector selectorTuple.unwrappedSelector;// 初始化成员变量selectStrategy为传入的strategyselectStrategy strategy;
}这个构造函数的作用是初始化NioEventLoop实例的成员变量。
它首先调用父类SingleThreadEventExecutor的构造函数然后检查传入的selectorProvider和selectStrategy是否为null如果是则抛出NullPointerException。
接着将传入的selectorProvider赋值给成员变量provider并调用openSelector()方法打开一个新的Selector并将返回的SelectorTuple中的selector和unwrappedSelector分别赋值给成员变量selector和unwrappedSelector。
最后将传入的strategy赋值给成员变量selectStrategy。
总的来说这个构造函数的作用是初始化NioEventLoop实例的成员变量包括selector、unwrappedSelector、provider和selectStrategy。 重点关注 super(parent, executor, false, DEFAULT_MAX_PENDING_TASKS, rejectedExecutionHandler); 和 final SelectorTuple selectorTuple openSelector(); super(parent, executor, false, DEFAULT_MAX_PENDING_TASKS, rejectedExecutionHandler) protected SingleThreadEventLoop(EventLoopGroup parent, Executor executor,boolean addTaskWakesUp, int maxPendingTasks,RejectedExecutionHandler rejectedExecutionHandler) {// 调用父类SingleThreadEventExecutor的构造函数创建一个新的实例super(parent, executor, addTaskWakesUp, maxPendingTasks, rejectedExecutionHandler);// 初始化tailTasks使用newTaskQueue方法创建一个新的任务队列tailTasks newTaskQueue(maxPendingTasks);
}
这段代码是SingleThreadEventLoop类的受保护构造函数的实现用于创建一个新的SingleThreadEventLoop实例。
这个构造函数的作用是创建一个新的SingleThreadEventLoop实例并初始化它的成员变量。首先调用父类SingleThreadEventExecutor的构造函数然后使用newTaskQueue方法创建一个新的任务队列tailTasks并将其赋值给成员变量tailTasks。
总的来说这个构造函数的作用是初始化SingleThreadEventLoop实例的成员变量并设置其父类、执行器、任务唤醒标志、最大挂起任务数和拒绝执行处理器 super(parent, executor, addTaskWakesUp, maxPendingTasks, rejectedExecutionHandler) 这段代码是SingleThreadEventExecutor类的受保护构造函数的实现用于创建一个新的SingleThreadEventExecutor实例。让我们逐步解释这段代码的实现
protected SingleThreadEventExecutor(EventExecutorGroup parent, Executor executor,boolean addTaskWakesUp, int maxPendingTasks,RejectedExecutionHandler rejectedHandler) {// 调用父类构造函数设置父类EventExecutorGroupsuper(parent);// 设置是否唤醒线程的标志this.addTaskWakesUp addTaskWakesUp;// 设置最大挂起任务数确保最小为16this.maxPendingTasks Math.max(16, maxPendingTasks);// 应用ThreadExecutorMap确保executor为非空this.executor ThreadExecutorMap.apply(executor, this);// 初始化任务队列taskQueue newTaskQueue(this.maxPendingTasks);// 设置拒绝执行处理器rejectedExecutionHandler ObjectUtil.checkNotNull(rejectedHandler, rejectedHandler);
}这个构造函数的作用是创建一个新的SingleThreadEventExecutor实例并设置其成员变量。它首先调用父类的构造函数设置父类EventExecutorGroup。然后根据传入的参数设置是否唤醒线程的标志addTaskWakesUp、最大挂起任务数maxPendingTasks、执行器executor以及拒绝执行处理器rejectedExecutionHandler。
总的来说这个构造函数的作用是初始化SingleThreadEventExecutor实例的成员变量并设置其父类、执行器、唤醒线程标志、最大挂起任务数和拒绝执行处理器。 tailTasks newTaskQueue(maxPendingTasks); 这段代码是SingleThreadEventExecutor类中的一个方法newTaskQueue()的实现。这个方法用于创建一个任务队列用于存储待执行的任务。
让我们逐步解释这段代码的实现 protected QueueRunnable newTaskQueue(int maxPendingTasks) {// 创建一个LinkedBlockingQueue实例作为任务队列并设置最大容量为maxPendingTasksreturn new LinkedBlockingQueueRunnable(maxPendingTasks);
}这个方法的作用是创建一个新的任务队列用于存储待执行的任务。默认实现使用了LinkedBlockingQueue它是一个基于链表的阻塞队列具有无界的容量但可以通过maxPendingTasks参数设置最大容量。如果子类重写这个方法并且不会对队列执行阻塞调用可以选择返回一个不支持阻塞操作的更高性能的实现。
总的来说newTaskQueue()方法的作用是创建一个任务队列并返回该队列的实例。 final SelectorTuple selectorTuple openSelector() 这段代码是NioEventLoop类中的一个方法openSelector()的实现用于打开一个新的Selector。让我们逐步解释这段代码的实现
private SelectorTuple openSelector() {// 声明一个未包装的Selectorfinal Selector unwrappedSelector;try {// 尝试打开一个新的SelectorunwrappedSelector provider.openSelector();} catch (IOException e) {// 打开Selector失败抛出异常throw new ChannelException(failed to open a new selector, e);}// 如果禁用了选择键集合优化则返回一个包含未包装的Selector的SelectorTupleif (DISABLE_KEY_SET_OPTIMIZATION) {return new SelectorTuple(unwrappedSelector);}// 尝试获取SelectorImpl类Object maybeSelectorImplClass AccessController.doPrivileged(new PrivilegedActionObject() {Overridepublic Object run() {try {return Class.forName(sun.nio.ch.SelectorImpl,false,PlatformDependent.getSystemClassLoader());} catch (Throwable cause) {return cause;}}});// 如果没有获取到类或者当前的Selector实现不是我们要的实现则返回一个包含未包装的Selector的SelectorTupleif (!(maybeSelectorImplClass instanceof Class) ||!((Class?) maybeSelectorImplClass).isAssignableFrom(unwrappedSelector.getClass())) {if (maybeSelectorImplClass instanceof Throwable) {Throwable t (Throwable) maybeSelectorImplClass;logger.trace(failed to instrument a special java.util.Set into: {}, unwrappedSelector, t);}return new SelectorTuple(unwrappedSelector);}// 获取到了SelectorImpl类尝试使用Unsafe替换SelectionKeySetfinal Class? selectorImplClass (Class?) maybeSelectorImplClass;final SelectedSelectionKeySet selectedKeySet new SelectedSelectionKeySet();// 使用反射设置Selector的selectedKeys和publicSelectedKeys字段为选定的键集Object maybeException AccessController.doPrivileged(new PrivilegedActionObject() {Overridepublic Object run() {try {// 获取selectedKeys和publicSelectedKeys字段Field selectedKeysField selectorImplClass.getDeclaredField(selectedKeys);Field publicSelectedKeysField selectorImplClass.getDeclaredField(publicSelectedKeys);// 如果当前Java版本大于等于9并且具有Unsafe支持则尝试使用Unsafe替换SelectionKeySetif (PlatformDependent.javaVersion() 9 PlatformDependent.hasUnsafe()) {// 使用Unsafe替换SelectionKeySetlong selectedKeysFieldOffset PlatformDependent.objectFieldOffset(selectedKeysField);long publicSelectedKeysFieldOffset PlatformDependent.objectFieldOffset(publicSelectedKeysField);if (selectedKeysFieldOffset ! -1 publicSelectedKeysFieldOffset ! -1) {PlatformDependent.putObject(unwrappedSelector, selectedKeysFieldOffset, selectedKeySet);PlatformDependent.putObject(unwrappedSelector, publicSelectedKeysFieldOffset, selectedKeySet);return null;}// 无法检索偏移量尝试反射作为最后的手段。}// 尝试设置字段的访问权限Throwable cause ReflectionUtil.trySetAccessible(selectedKeysField, true);if (cause ! null) {return cause;}cause ReflectionUtil.trySetAccessible(publicSelectedKeysField, true);if (cause ! null) {return cause;}// 设置选定的键集到Selector的selectedKeys和publicSelectedKeys字段selectedKeysField.set(unwrappedSelector, selectedKeySet);publicSelectedKeysField.set(unwrappedSelector, selectedKeySet);return null;} catch (NoSuchFieldException e) {return e;} catch (IllegalAccessException e) {return e;}}});// 如果出现异常则返回一个包含未包装的Selector的SelectorTupleif (maybeException instanceof Exception) {selectedKeys null;Exception e (Exception) maybeException;logger.trace(failed to instrument a special java.util.Set into: {}, unwrappedSelector, e);return new SelectorTuple(unwrappedSelector);}// 成功设置选定的键集记录日志并返回一个包含未包装的Selector和SelectedSelectionKeySetSelector的SelectorTupleselectedKeys selectedKeySet;logger.trace(instrumented a special java.util.Set into: {}, unwrappedSelector);return new SelectorTuple(unwrappedSelector,new SelectedSelectionKeySetSelector(unwrappedSelector, selectedKeySet));
}这个方法的作用是打开一个新的Selector并尝试优化其内部的SelectionKey集合。
首先它尝试直接打开一个新的Selector如果失败则抛出异常。
然后它检查是否禁用了选择键集合优化。如果没有禁用则尝试获取sun.nio.ch.SelectorImpl类并验证当前Selector的实现是否与获取的类兼容。如果兼容则尝试使用Unsafe替换SelectionKeySet以提高性能。
最后返回一个包含未包装的Selector和可能的SelectedSelectionKeySetSelector的SelectorTuple。 小结
NioEventLoopGroup是Netty中用于处理NIO事件的事件循环组。
下面我们总结下NioEventLoopGroup源码 构造函数NioEventLoopGroup类提供了多个构造函数用于创建实例。这些构造函数允许指定线程数量、执行器、选择器提供者和选择策略工厂等参数。构造函数内部会调用父类MultithreadEventLoopGroup的构造函数并设置相关参数。 多线程事件循环组NioEventLoopGroup继承自MultithreadEventLoopGroup类用于管理多个NioEventLoop实例。它负责创建和管理一组NioEventLoop线程每个线程处理一个Selector的事件循环。 打开新的SelectorNioEventLoopGroup内部使用openSelector()方法来打开一个新的Selector。该方法尝试优化Selector的内部SelectionKey集合以提高性能。优化过程包括尝试使用Unsafe替换SelectionKeySet以更有效地处理SelectionKey的集合。 任务队列NioEventLoopGroup内部使用任务队列来存储待执行的任务。默认情况下它使用LinkedBlockingQueue作为任务队列但允许子类重写newTaskQueue()方法以选择更高性能的实现。 执行器和拒绝策略NioEventLoopGroup使用执行器来执行任务并提供拒绝执行处理器来处理任务执行失败的情况。
总的来说NioEventLoopGroup源码实现了一个用于管理和处理NIO事件的多线程事件循环组它提供了灵活的构造函数和优化的Selector打开机制以提高整体性能和并发能力。
