2019-05-18 NioEventLoop的初始化

通过以下这行代码创建SubReactor线程组,也就是NioEventLoop线程组；

image.png image.png

构造一个SelectorProvider.provider(),这个provider就负责创建每个NioEventLoop维护的selector，同时初始化一个默认选择器执行策略

image.png

传入一个默认的线程选择器

image.png

创建一个默认的ThreadPerTaskExecutor，每次执行任务的时候都会创建一个线程，初始化是通过DefaultThreadFactory来创建的；

image.png

每次调用execute方法都会创建一个线程

image.png

构造DefaultThreadFactory，初始化线程的名称前缀

image.png image.png

初始化NioEventLoop线程的名称前缀

image.png

创建线程的时候会将这个线程名传入对应的构造函数

image.png

netty中对jdk的Thread做了一层封装

image.png image.png

创建NioEventLoop

image.png

代码在io.netty.channel.nio.NioEventLoopGroup#newChild这里实现，args参数如下

image.png image.png

构造函数中设置executor,线程拒绝策略，taskQueue等

image.png

taskQueue:外部线程在执行netty的任务的时候,如果判断不是在NioEventLoop对应的线程里面去执行,这些任务会直接丢到一个任务队列中,然后由NioEventloop对应的线程去执行过程，初始化调用jdk底层初始化一个mscpQueue

image.png

mpscQueue(multi producer single consumer)，multi producer对应的就是非Nio线程，Single consumer 就是netty的一个NioEventLoop线程，也就是说外部线程可以丢进来，由一个NioEventLoop去消费

image.png

最后就是绑定selector操作，注意看，其实每一个NioEventLoop都有一个对应的selector

image.png

最后创建EventExecutorChooser，chooser其实就是给新链接绑定NioEventLoop

image.png

NioEventLoop启动，通过dobind0方法新起一个Runnable进行端口绑定

image.png

什么时候channel绑定的NioEventLoop嘞？在这个地方实现的netty通过java.nio.channels.SelectableChannel#register(java.nio.channels.Selector, int, java.lang.Object)方法将自身实现的NioSocketChannel和SelectionKey,原生的socket channel绑定在了一起

image.png

接下来看下execute方法，代码实现在io.netty.util.concurrent.SingleThreadEventExecutor#execute,这里inEventLoop返回false，所以就会启动一个新线程，并往TaskQueue添加任务

image.png

判断是不是NioEventLoop，这时候SingleThreadEventExecuto中的Thread的null，肯定不是当前主线程

image.png

启动线程，通过CAS判断当前线程是不是未启动的

image.png

接下来调用executor新建一个线程

image.png image.png

首先保存当前线程，其实也就是将NioEventLoop与这个thread进行绑定

image.png

然后调用run方法进行实际的启动，其实这才是NioEventLoop的真实启动。

image.png

接下来就进入了NioEventLoop的run方法的执行了，这个我们后面再分析。