添加EventExecutorGroup

public abstract class MultithreadEventExecutorGroup extends AbstractEventExecutorGroup {protected MultithreadEventExecutorGroup(int nThreads, Executor executor,                                            EventExecutorChooserFactory chooserFactory, Object... args) {        if (nThreads <= 0) {            throw new IllegalArgumentException(String.format("nThreads: %d (expected: > 0)", nThreads));        }        if (executor == null) {            executor = new ThreadPerTaskExecutor(newDefaultThreadFactory());        }        children = new EventExecutor[nThreads];        for (int i = 0; i < nThreads; i ++) {            boolean success = false;            try {                children[i] = newChild(executor, args);                success = true;            } catch (Exception e) {                // TODO: Think about if this is a good exception type                throw new IllegalStateException("failed to create a child event loop", e);            } finally {                if (!success) {                    for (int j = 0; j < i; j ++) {                        children[j].shutdownGracefully();                    }                    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;                        }                    }                }            }        }        chooser = chooserFactory.newChooser(children);        final FutureListener

bind

private static void doBind0(            final ChannelFuture regFuture, final Channel channel,            final SocketAddress localAddress, final ChannelPromise promise) {        // This method is invoked before channelRegistered() is triggered.  Give user handlers a chance to set up        // the pipeline in its channelRegistered() implementation.        channel.eventLoop().execute(new Runnable() { //提交/执行任务            @Override            public void run() { //业务方法                if (regFuture.isSuccess()) {                    channel.bind(localAddress, promise).addListener(ChannelFutureListener.CLOSE_ON_FAILURE); //                } else {                    promise.setFailure(regFuture.cause());                }            }        });    }复制代码

@Override    public ChannelFuture bind(final SocketAddress localAddress, final ChannelPromise promise) {        if (localAddress == null) {            throw new NullPointerException("localAddress");        }        if (!validatePromise(promise, false)) {            // cancelled            return promise;        }        final AbstractChannelHandlerContext next = findContextOutbound();        EventExecutor executor = next.executor();        if (executor.inEventLoop()) {            next.invokeBind(localAddress, promise);        } else {            safeExecute(executor, new Runnable() {                @Override                public void run() {                    next.invokeBind(localAddress, promise);                }            }, promise, null);        }        return promise;    }复制代码

abstract class AbstractChannelHandlerContext extends DefaultAttributeMap        implements ChannelHandlerContext, ResourceLeakHint {@Override    public ChannelFuture connect(            final SocketAddress remoteAddress, final SocketAddress localAddress, final ChannelPromise promise) {        if (remoteAddress == null) {            throw new NullPointerException("remoteAddress");        }        if (!validatePromise(promise, false)) {            // cancelled            return promise;        }        final AbstractChannelHandlerContext next = findContextOutbound();        EventExecutor executor = next.executor();        if (executor.inEventLoop()) {            next.invokeConnect(remoteAddress, localAddress, promise);        } else {            safeExecute(executor, new Runnable() {                @Override                public void run() {                    next.invokeConnect(remoteAddress, localAddress, promise);                }            }, promise, null);        }        return promise;    }复制代码

class ServerSocketChannelImpl    extends ServerSocketChannel    implements SelChImpl{@Override    public ServerSocketChannel bind(SocketAddress local, int backlog) throws IOException {        synchronized (lock) {            if (!isOpen())                throw new ClosedChannelException();            if (isBound())                throw new AlreadyBoundException();            InetSocketAddress isa = (local == null) ? new InetSocketAddress(0) :                Net.checkAddress(local);            SecurityManager sm = System.getSecurityManager();            if (sm != null)                sm.checkListen(isa.getPort());            NetHooks.beforeTcpBind(fd, isa.getAddress(), isa.getPort());            Net.bind(fd, isa.getAddress(), isa.getPort()); //最终还是调用ServerSocketChannelImpl.bind            Net.listen(fd, backlog < 1 ? 50 : backlog);             synchronized (stateLock) {                localAddress = Net.localAddress(fd);            }        }        return this;    }复制代码

addListener()

public class DefaultChannelPromise extends DefaultPromise
    
      implements ChannelPromise, FlushCheckpoint {@Override    public ChannelPromise addListener(GenericFutureListener
     > listener) {        super.addListener(listener);        return this;    }复制代码