05、Netty源码分析:NioEventLoop构造函数

链接:《Netty》从零开始学netty源码(四)之NioEventLoop

在前面介绍过NioEventLoopGroup的构造函数中会调用newChild方法创建NioEventLoop,如下

*

newChild方法如下

*

NioEventLoop的构造函数整个过程如下:

*

在这个过程中主要是赋值NioEventLoop的参数,有一些参数的值需要再详细分析:

1、 maxPendingTasks;
2、 executor;
3、 taskQueue与tailTasks;
4、 rejectedExecutionHandler;
5、 selectStrategy;
6、 openSelector();

maxPendingTasks

*

如果配置了系统参数io.netty.eventexecutor.maxPendingTasks则取其值,否则用Integer.MAX_VALUE;然后再和16比较,取两者较大值。默认情况下值为Integer.MAX_VALUE

taskQueue与tailTasks

两者都调用了newTaskQueue方法创建queue,从前面的newChild方法可知两者传进去的queueFactory都为null,创建过程如下:
*

从源码可知,默认情况下会创建一个大小为1024(初始大小)的MpscUnboundedArrayQueue,是一个无锁的多生产者单消费者队列,与原生的java队列相比它是无锁的,通过底层Unsafe采用CAS操作实现线程安全,虽然会造成一定CPU损耗,但因为无锁减少了线程切换,整体效率更佳。

版权声明:本文不是「本站」原创文章,版权归原作者所有 | 原文地址: