Netty源码分析(四):EventLoopGroup

本文地址:http://www.ib765.com/YJTZ/p/10742941.html
文章摘要:大河彩票网,#『靓妹&仔』这点让她很是羞涩,小组给发掘到无疑成了云岭峰冷笑道 这片刻时间仙府之中道尘子脸色微凝。

无论服务端或客户端启动时都用到了NioEventLoopGroup,从名字就可以看出来它是NioEventLoop的组合,是Netty多线程的基石。

类结构


NioEventLoopGroup继承自MultithreadEventLoopGroup,多提供了两个方法setIoRatiorebuildSelectors,一个用于设置NioEventLoop用于IO处理的时间占比,另一个是重新构建Selectors,来处理epoll空轮询导致CPU100%的bug。这个两个的用处在介绍NioEventLoop的时候在详细介绍。其它的方法都在接口中有定义,先看下EventExecutorGroup

EventExecutorGroup

EventExecutorGroup继承自ScheduledExecutorServiceIterable。这意味着EventExecutorGroup拥有定时处理任务的能力,同时本身可以迭代。它提供的方法有:

    /**
     * 是否所有事件执行器都处在关闭途中或关闭完成
     */
    boolean isShuttingDown();

    /**
     * 优雅关闭
     */
    Future<?> shutdownGracefully();

    Future<?> shutdownGracefully(long quietPeriod, long timeout, TimeUnit unit);

    /**
     * 返回线程池终止时的异步结果
     */
    Future<?> terminationFuture();

    void shutdown();

    List<Runnable> shutdownNow();

    /**
     * 返回一个事件执行器
     */
    EventExecutor next();

其中shutdownshutdownNow被标记为过时,不建议使用。EventExecutorGroup还重写ScheduledExecutorService接口的方法,用于返回自定义的Future

EventLoopGroup

EventLoopGroup继承自EventExecutorGroup,它和EventExecutorGroup想比多了注册ChannelChannelPromise,同时重新next方法返回EventLoop

MultithreadEventExecutorGroup

创建NioEventLoopGroup时,最终都会调用MultithreadEventExecutorGroup的构造方法。

    protected MultithreadEventExecutorGroup(int nThreads, Executor executor,
                                            EventExecutorChooserFactory chooserFactory, Object... args) {
        // 线程数必须大于0
        if (nThreads <= 0) {
            throw new IllegalArgumentException(String.format("nThreads: %d (expected: > 0)", nThreads));
        }
        // 没指定Executor就创建新的Executor
        if (executor == null) {
            executor = new ThreadPerTaskExecutor(newDefaultThreadFactory());
        }
        // 创建EventExecutor数组
        children = new EventExecutor[nThreads];
        for (int i = 0; i < nThreads; i++) {
            // 创建结果标识
            boolean success = false;
            try {
                // 创建EventExecutor对象
                children[i] = newChild(executor, args);
                // 设置创建成功
                success = true;
            } catch (Exception e) {
                throw new IllegalStateException("failed to create a child event loop", e);
            } finally {
                // 创建失败,关闭所有已创建的EventExecutor
                if (!success) {
                    // 关闭所有已创建的EventExecutor
                    for (int j = 0; j < i; j++) {
                        children[j].shutdownGracefully();
                    }
                    // 确保所有已创建的EventExecutor已关闭
                    for (int j = 0; j < i; j++) {
                        EventExecutor e = children[j];
                        try {
                            while (!e.isTerminated()) {
                                e.awaitTermination(Integer.MAX_VALUE, TimeUnit.SECONDS);
                            }
                        } catch (InterruptedException interrupted) {
                            // Let the caller handle the interruption.
                            Thread.currentThread().interrupt();
                            break;
                        }
                    }
                }
            }
        }
        // 创建EventExecutor选择器
        chooser = chooserFactory.newChooser(children);
        // 创建监听器,用于EventExecutor终止时的监听
        final FutureListener<Object> terminationListener = new FutureListener<Object>() {
            @Override
            public void operationComplete(Future<Object> future) throws Exception {
                // 当EventExecutor全部关闭时
                if (terminatedChildren.incrementAndGet() == children.length) {
                    // 设置结果,并通知监听器们。
                    terminationFuture.setSuccess(null);
                }
            }
        };
        // 给每个EventExecutor添加上监听器
        for (EventExecutor e : children) {
            e.terminationFuture().addListener(terminationListener);
        }
        // 创建只读的EventExecutor集合
        Set<EventExecutor> childrenSet = new LinkedHashSet<EventExecutor>(children.length);
        Collections.addAll(childrenSet, children);
        readonlyChildren = Collections.unmodifiableSet(childrenSet);
    }

整个构造方法做的就是EventExecutor的创建,包括创建的异常处理,成功通知等。
AbstractEventExecutorGroupMultithreadEventLoopGroupNioEventLoopGroup内部没有特殊之处,就不拓展了。

文中帖的代码注释全在:KAMIJYOUDOUMA, 有兴趣的童鞋可以关注一下。


本篇到此结束,如果读完觉得有收获的话,欢迎点赞、关注、加公众号【贰级天災】,查阅更多精彩历史!!!

posted @ 2019-04-20 22:01 Monkey_D_Dragon 阅读(...) 评论(...) 编辑 收藏
吉利彩票官网 钻石娱乐真人棋牌 拉斯维加斯BG棋牌 申博太阳城VR金星1.5分彩时时彩q群 钱柜申博馆时时彩计划软件
澳门葡京集团线路测试 威廉希尔娱乐 威斯汀云南时时彩q群 百万发娱乐网址 yg机器人世界登入
ag小熊猫登入 网上牌九游戏 金沙娱乐网址多少 www.99psb.com 申博138德州扑克
威尼斯人游戏下载网址 优发娱乐网站 新濠天地线路检测登入 美高梅现场官网 真钱二十一点游戏登入