皮皮网

1.Java的码解并行世界-Netty中线程模型源码讲解-续集EventLoopGroup和EventLoop【全网最深入的group分析】
2.Netty源码解析 -- FastThreadLocal与HashedWheelTimer

Java的并行世界-Netty中线程模型源码讲解-续集EventLoopGroup和EventLoop【全网最深入的group分析】

       探讨EventLoopGroup在Netty中的重要性，它管理并调度事件循环，码解扮演线程池角色。码解EventLoopGroup包含一个或多个EventLoop，码解用于处理事件驱动任务，码解如网络I/O、码解vs stl调试源码定时任务等。码解EventLoop是码解Netty的核心概念之一，负责驱动网络通信和事件处理。码解

       在ServerBootstrap中绑定group

       // 创建 bossGroup 和 workerGroup

       EventLoopGroup bossGroup =newNioEventLoopGroup(1); // 1 个线程用于接收连接请求

       EventLoopGroup workerGroup =newNioEventLoopGroup(); // 默认线程数量用于处理连接的码解读写操作

       Java NIO和Linux的Epoll是两种不同I/O模型，用于处理非阻塞I/O操作，码解但存在平台依赖性、码解事件驱动机制、码解星夜直播源码app性能、码解适用场景和可扩展性上的码解区别。

       NioEventLoopGroup和EpollEventLoopGroup是Netty的封装，接下来分析其设计。

       NioEventLoopGroup和EpollEventLoopGroup在继承关系上相同，可从以下两个方向分析：

       (1) 通用部分，MultithreadEventLoopGroup向上做了哪些？

       其代码主要分为三大类：

       构造函数：有三个参数 - 线程数量、线程池控制（线程工厂和执行器）和EventExecutorChooserFactory。

       线程数量参数用于初始化事件循环组中的线程数量。

       线程池控制参数用于指定线程创建和执行的自定义方式。

       EventExecutorChooserFactory用于创建EventExecutorChooser实例，实现负载均衡策略。数字藏品源码php

       (2) Nio和Epoll两个EventLoopGroup的内部方法做了哪些？

       它们在源码实现上基本一致，区别在于调用方式；如设置I/O操作比例、rebuildSelectors方法（Netty自动处理底层问题，通常无需手动调用）和创建EventLoop。

       EventLoopGroup接口规范了事件执行器管理与调度的操作，而NioEventLoopGroup和EpollEventLoopGroup具体实现这些接口。

       总体而言，EventLoopGroup在Netty中提供了一个灵活、高效的事件驱动机制，允许开发者根据应用需求和操作系统环境选择合适的I/O模型。

Netty源码解析 -- FastThreadLocal与HashedWheelTimer

       Netty源码分析系列文章接近尾声，本文深入解析FastThreadLocal与HashedWheelTimer。书源管理源码基于Netty 4.1.版本。

       FastThreadLocal简介：

       FastThreadLocal与FastThreadLocalThread协同工作。FastThreadLocalThread继承自Thread类，内部封装一个InternalThreadLocalMap，该map只能用于当前线程，存放了所有FastThreadLocal对应的值。每个FastThreadLocal拥有一个index，用于定位InternalThreadLocalMap中的值。获取值时，首先检查当前线程是否为FastThreadLocalThread，如果不是，则从UnpaddedInternalThreadLocalMap.slowThreadLocalMap获取InternalThreadLocalMap，哈希趣投源码这实际上回退到使用ThreadLocal。

       FastThreadLocal获取值步骤：

       #1 获取当前线程的InternalThreadLocalMap，如果是FastThreadLocalThread则直接获取，否则通过UnpaddedInternalThreadLocalMap.slowThreadLocalMap获取。

       #2 通过每个FastThreadLocal的index，获取InternalThreadLocalMap中的值。

       #3 若找不到值，则调用initialize方法构建新对象。

       FastThreadLocal特点：

       FastThreadLocal无需使用hash算法，通过下标直接获取值，复杂度为log(1)，性能非常高效。

       HashedWheelTimer介绍：

       HashedWheelTimer是Netty提供的时间轮调度器，用于高效管理各种延时任务。时间轮是一种批量化任务调度模型，能够充分利用线程资源。简单说，就是将任务按照时间间隔存放在环形队列中，执行线程定时执行队列中的任务。

       例如，环形队列有个格子，执行线程每秒移动一个格子，则每轮可存放1分钟内的任务。任务执行逻辑如下：给定两个任务task1（秒后执行）、task2（2分秒后执行），当前执行线程位于第6格子。那么，task1将放到+6=格，轮数为0；task2放到+6=格，轮数为2。执行线程将执行当前格子轮数为0的任务，并将其他任务轮数减1。

       HashedWheelTimer的缺点：

       时间轮调度器的时间精度受限于执行线程的移动速度。例如，每秒移动一个格子，则调度精度小于一秒的任务无法准时调用。

       HashedWheelTimer关键字段：

       添加延迟任务时，使用HashedWheelTimer#newTimeout方法，如果HashedWheelTimer未启动，则启动HashedWheelTimer。启动后，构建HashedWheelTimeout并添加到timeouts集合。

       HashedWheelTimer运行流程：

       启动后阻塞HashedWheelTimer线程，直到Worker线程启动完成。计算下一格子开始执行的时间，然后睡眠到下次格子开始执行时间。获取tick对应的格子索引，处理已到期任务，移动到下一个格子。当HashedWheelTimer停止时，取消任务并停止时间轮。

       HashedWheelTimer性能比较：

       HashedWheelTimer新增任务复杂度为O(1)，优于使用堆维护任务的ScheduledExecutorService，适合处理大量任务。然而，当任务较少或无任务时，HashedWheelTimer的执行线程需要不断移动，造成性能消耗。另外，使用同一个线程调用和执行任务，某些任务执行时间过久会影响后续任务执行。为避免这种情况，可在任务中使用额外线程执行逻辑。如果任务过多，可能导致任务长期滞留在timeouts中而不能及时执行。

       本文深入剖析FastThreadLocal与HashedWheelTimer的实现细节，旨在提供全面的技术洞察与实战经验。希望对您理解Netty源码与时间轮调度器有帮助。关注微信公众号，获取更多Netty源码解析与技术分享。