七 Netty 学习：NioEventLoop 对应线程的创建和启动源码说明 _生活百科

原文地址：
博客园：Netty 学习（七）：NioEventLoop 对应线程的创建和启动源码说明
CSDN：Netty 学习（七）：NioEventLoop 对应线程的创建和启动源码说明
说明在 Netty 服务端代码中，我们一般会创建了两个 NioEventLoopGroup：bossGroup 和 workerGroup
其中: bossGroup用于监听端口，接收新连接的线程组；workerGroup 用于处理每一个连接的数据读写的线程组。
bossGroup 创建第一个 NioEventLoop 线程NioEventLoop 的启动入口在AbstractUnsafe
        @Override        public final void register(EventLoop eventLoop, final ChannelPromise promise) {            ......            AbstractChannel.this.eventLoop = eventLoop;            if (eventLoop.inEventLoop()) {                register0(promise);            } else {                try {                    eventLoop.execute(new Runnable() {                        @Override                        public void run() {                            register0(promise);                        }                    });                } catch (Throwable t) {                    logger.warn(                            "Force-closing a channel whose registration task was not accepted by an event loop: {}",                            AbstractChannel.this, t);                    closeForcibly();                    closeFuture.setClosed();                    safeSetFailure(promise, t);                }            }        }其中inEventLoop()方法调用的是AbstractEventExecutor的实现
    @Override    public boolean inEventLoop() {        return inEventLoop(Thread.currentThread());    }而这个实现又调用了子类SingleThreadEventExecutor的如下方法
【七 Netty 学习：NioEventLoop 对应线程的创建和启动源码说明】    @Override    public boolean inEventLoop(Thread thread) {        return thread == this.thread;    }在服务端刚启动的时候，Thread.currentThread()就是当前 main 方法对应的主线程，而this.thread还没有开始赋值，所以此时为null，
所以eventLoop.inEventLoop()在一开始调用的时候，返回的是 false，进入AbstractUnsafe的如下else逻辑中
        @Override        public final void register(EventLoop eventLoop, final ChannelPromise promise) {            ......            AbstractChannel.this.eventLoop = eventLoop;            // 首次执行的时候 eventLoop.inEventLoop() 返回 false，执行 else 逻辑            if (eventLoop.inEventLoop()) {                ......            } else {               ......                    eventLoop.execute(new Runnable() {                        @Override                        public void run() {                            register0(promise);                        }                    });               ......            }        }

七 Netty 学习：NioEventLoop 对应线程的创建和启动源码说明

推荐阅读

职工医保和城乡居民医保哪个划算？交哪个好

关于来不及诉说简述来不及诉说

荞麦茶的功效有哪些荞麦茶有什么作用功效

大连金普新区文旅场馆7月19日起取消查验核酸报告

形容教室里很多人的成语

伊美婷成分伊美婷胶原蛋白安全吗

攀升MaxBook P2参数_攀升MaxBook P2配置

铝锅煮汤对人体有害吗，不建议经常使用铝锅煮汤

王丽云主演的电视剧有哪些王丽云演的全部电视剧

《四季豆一定要焯水吗》

属兔的适合住什么楼层最好住几楼大吉？

鱼鳞痣怎么祛除掉鱼鳞痣怎么祛除

保护视力的绘画作品保护视力的绘画作品画法

芋头和香芋一样吗？芋头什么人不能多吃

白羊座最适合的运动

越在乎你才会越嫌弃你的星座，天蝎上榜！

发朋友圈运动的幽默句子发朋友圈运动句子

肉煎饺的做法步骤肉煎饺的做法步骤

电脑版微信怎么发朋友圈电脑版微信怎么发朋友圈视频

江苏省公务员abc类区别江苏省公务员abc类的区别