文档章节

NioEventLoopGroup继承层次结构图

健康的程序员
 健康的程序员
发布于 2017/03/12 11:37
字数 641
阅读 16
收藏 0

NioEventLoopGroup继承层次结构图

Netty4的NioEventLoopGroup继承结构很复杂,为了理解它如何工作,我画了一张类似UML的图。但是这张图也很巨大,所以我做了以下处理:

  • 将位于不同中的类或接口用不同的颜色加以区分

  • 接口名后面的括号里标注了大写字母I(Interface),抽象类名的后面标注了大写字母A(Abstract)

  • 每个类或接口,只列出了我认为最重要的一个方法

 

EventExecutorGroup

首先从EventExecutorGroup开始,EventExecutorGroup是NioEventLoopGroup最上层的接口,再往上就是Java的地盘了:

 

从上面的图可以看出3点:

  1. EventExecutorGroup接口继承了java.util.concurrent.ScheduledExecutorService接口,因此它可以调度执行task
  2. EventExecutorGroup内部管理了n个EventExecutornext()方法返回其中的一个
  3. EventExecutor也是EventExecutorGroup(的子类)

想象一下,EventExecutorGroup就像一个BOSS,每当有活儿的时候,就派一个小弟(EventExecutor)去干:

 

AbstractEventExecutorGroup

AbstractEventExecutorGroup抽象类实现了ScheduledExecutorService接口,但大部分实现都只是调用next()拿到一个EventExecutor,然后调用EventExecutor的相应方法,例如submit()方法:

 

[java] view plain copy

 在CODE上查看代码片派生到我的代码片

  1. public abstract class AbstractEventExecutorGroup implements EventExecutorGroup {  
  2.   
  3.     @Override  
  4.     public Future<?> submit(Runnable task) {  
  5.         return next().submit(task);  
  6.     }  
  7.     ...  
  8. }  

 

 

 

MultithreadEventExecutorGroup

从类名来看,MultithreadEventExecutorGroup有并行(多线程)分配小弟去干活的能力,换句话说,每个小弟都工作在自己的线程中。从代码中也能看出这一点:

 

[java] view plain copy

 在CODE上查看代码片派生到我的代码片

  1. public abstract class MultithreadEventExecutorGroup extends AbstractEventExecutorGroup {  
  2.   
  3.     private final EventExecutor[] children;  
  4.     private final AtomicInteger childIndex = new AtomicInteger();  
  5.     private final AtomicInteger terminatedChildren = new AtomicInteger();  
  6.     private final Promise<?> terminationFuture = new DefaultPromise(GlobalEventExecutor.INSTANCE);  
  7.   
  8.     protected MultithreadEventExecutorGroup(int nThreads, ThreadFactory threadFactory, Object... args) {  
  9.         ...  
  10.         children = new SingleThreadEventExecutor[nThreads];  
  11.         ...  
  12.     }  
  13.   
  14.     ...  
  15. }  

可以看出,MultithreadEventExecutorGroup的每一个小弟都是一个SingleThreadEventExecutor,而且小弟的数量在构造的时候就确定了,如下图所示:

 

 

 

从MultithreadEventExecutorGroup的next()方法可以看到,这个BOSS的小弟分配逻辑相当简单,无非就是轮流使唤:

 

[java] view plain copy

 在CODE上查看代码片派生到我的代码片

  1. @Override  
  2. public EventExecutor next() {  
  3.     return children[Math.abs(childIndex.getAndIncrement() % children.length)];  
  4. }  

注:这里调用了Math.abs()方法以防止childIndex溢出

 

 

MultithreadEventLoopGroup

MultithreadEventLoopGroup类实现了EventLoopGroup接口和register()方法:

 

[java] view plain copy

 在CODE上查看代码片派生到我的代码片

  1. public abstract class MultithreadEventLoopGroup extends MultithreadEventExecutorGroup implements EventLoopGroup {  
  2.     ...  
  3.       
  4.     @Override  
  5.     public ChannelFuture register(Channel channel) {  
  6.         return next().register(channel);  
  7.     }  
  8.   
  9.     @Override  
  10.     public ChannelFuture register(Channel channel, ChannelPromise promise) {  
  11.         return next().register(channel, promise);  
  12.     }  
  13. }  

 

 

NioEventLoopGroup

最后是NioEventLoopGroup,这个BOSS的每一个小弟都是一个NioEventLoop。下面是完整的继承层次结构图:

 

结论

  • NioEventLoopGroup实际上就是个线程池
  • NioEventLoopGroup在后台启动了n个NioEventLoop来处理Channel事件
  • 每一个NioEventLoop负责处理m个Channel
  • NioEventLoopGroup从NioEventLoop数组里挨个取出NioEventLoop来处理Channel

本文转载自:http://blog.csdn.net/zxhoo/article/details/17634683

健康的程序员
粉丝 9
博文 196
码字总数 51976
作品 0
杭州
程序员
私信 提问
Netty 源码分析之 三 我就是大名鼎鼎的 EventLoop(一)

目录 源码之下无秘密 ── 做最好的 Netty 源码分析教程 Netty 源码分析之 番外篇 Java NIO 的前生今世 Java NIO 的前生今世 之一 简介 Java NIO 的前生今世 之二 NIO Channel 小结 Java NIO...

永顺
2017/11/29
0
0
56. Netty服务器端启动源代码分析

一. 代码下载 Netty代码下载和编译参考前一篇Netty文章 http://blog.51cto.com/483181/2112163 二. 服务器代码分析 2.1 服务器代码编写 一般Netty服务器端这样编写 2.2 NioEventLoopGroup 2....

rongwei84n
2018/05/21
0
0
博为峰Java技术文章 ——JavaSE Swing 按钮

博为峰小博老师: 下面是JButton的层次结构如下图所示: 由以上的JButton的层次结构图可以看出,JButton是继承AbstractButton类而来。AbstractButton本身是一个抽象类,里面定义了许多组件设置...

博为峰教研组
2016/12/28
4
0
netty(三) NioEventLoop再学习

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/lupeng/article/details/82503671 NioEventLoop再次学习 gitgub:NioEventLoop再学习 昨天开始学习了NioEventL...

孤落
2018/09/07
0
0
设计模式之五(策略模式)

前言 策略模式:它定义了算法家族,分别封装起来,让它们之间可以相互替换,此模式让算法的变化,不会影响到使用算法的客户。 策略模式结构图 Strategy:策略类,定义所有支持的算法的公共接...

aehyok
2013/05/29
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Spring使用ThreadPoolTaskExecutor自定义线程池及实现异步调用

多线程一直是工作或面试过程中的高频知识点,今天给大家分享一下使用 ThreadPoolTaskExecutor 来自定义线程池和实现异步调用多线程。 一、ThreadPoolTaskExecutor 本文采用 Executors 的工厂...

CREATE_17
今天
5
0
CSS盒子模型

CSS盒子模型 组成: content --> padding --> border --> margin 像现实生活中的快递: 物品 --> 填充物 --> 包装盒 --> 盒子与盒子之间的间距 content :width、height组成的 内容区域 padd......

studywin
今天
7
0
修复Win10下开始菜单、设置等系统软件无法打开的问题

因为各种各样的原因导致系统文件丢失、损坏、被修改,而造成win10的开始菜单、设置等系统软件无法打开的情况,可以尝试如下方法解决 此方法只在部分情况下有效,但值得一试 用Windows键+R打开...

locbytes
昨天
8
0
jquery 添加和删除节点

本文转载于:专业的前端网站➺jquery 添加和删除节点 // 增加一个三和一节点function addPanel() { // var newPanel = $('.my-panel').clone(true) var newPanel = $(".triple-panel-con......

前端老手
昨天
8
0
一、Django基础

一、web框架分类和wsgiref模块使用介绍 web框架的本质 socket服务端 与 浏览器的通信 socket服务端功能划分: 负责与浏览器收发消息(socket通信) --> wsgiref/uWsgi/gunicorn... 根据用户访问...

ZeroBit
昨天
10
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部