来自 netty.io 的netty示例的代码片段似乎有错误

Question

代码片段是：

        final ChannelFuture f = ctx.writeAndFlush(time); 
        f.addListener(new ChannelFutureListener() {

            public void operationComplete(ChannelFuture future) {
                assert f == future;
                ctx.close();
            }
        }); 

如果' final channel future f = CTX . writeandflush(time)；'会发生什么情况执行速度非常快，因此下一个< code>addListener代码还没有开始。当第一行代码完成时，线程通知所有侦听器操作完成，但在那个时候，根本没有侦听器！之后，添加了一个新的侦听器，但不会再收到通知！

代码源：http://netty.io/wiki/user-guide-for-5.x.html

Answer 1

ChannelFuture保留其完成状态，因此，如果在完成后添加了侦听器，则“延迟”添加的侦听器将在添加时立即回调。

请参阅channel future . add listener(GenericFutureListener)的javadoc，特别是注释:

如果这个future已经完成，指定的侦听器会立即得到通知。

请参阅DefaultPromise的impl。延迟侦听器（即在未来完成后添加的侦听器）有自己的处理程序（novfyLateListener）。