链接:《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损耗,但因为无锁减少了线程切换,整体效率更佳。
版权声明:本文不是「本站」原创文章,版权归原作者所有 | 原文地址: