Home / cs-notes / Architecture / Components / Netty / EventLoop / NioEventLoopGroup / register

• MultithreadEventLoopGroup

    @Override
    public ChannelFuture register(Channel channel) {
        return next().register(channel);
    }

    @Override
    public EventLoop next() {
        return (EventLoop) super.next();
    }

• MultithreadEventExecutorGroup

    @Override
    public EventExecutor next() {
        return chooser.next();
    }

• SingleThreadEventLoop

    @Override
    public ChannelFuture register(Channel channel) {
        return register(new DefaultChannelPromise(channel, this));
    }

    @Override
    public ChannelFuture register(final ChannelPromise promise) {
        ObjectUtil.checkNotNull(promise, "promise");
        promise.channel().unsafe().register(this, promise);
        return promise;
    }