Ein Code-Snippet netty Beispiele aus netty.io scheint Bugs

Question

Die Code-Snippet haben ist:

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

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

Was ist, wenn 'final ChannelFuture f geschieht = ctx.writeAndFlush (Zeit); 'führt sehr schnell aus, so dass der nächste addListener Code noch nicht startet. Wenn die erste Codezeile abgeschlossen ist, benachrichtigt der Thread alle Listener, dass die Operation ausgeführt wurde, aber zu diesem Zeitpunkt gibt es überhaupt keinen Listener! Danach wird ein neuer Listener hinzugefügt, aber es werden keine Benachrichtigungen mehr empfangen!

-Code Quelle: http://netty.io/wiki/user-guide-for-5.x.html

Answer 1

Der ChannelFuture behält seinen Vollendungszustand so, wenn ein Zuhörer nach Abschluss hinzugefügt wird, die „spät“, fügten Zuhörer bei der Zugabe sofort wieder aufgerufen wird.

Siehe javadoc für ChannelFuture.addListener(GenericFutureListener), speziell der Kommentar:

Wenn diese Zukunft bereits abgeschlossen ist, der angegebene Listener ist sofort benachrichtigt.

Siehe impl für DefaultPromise. Spätere Listener (d. H. Listener, die hinzugefügt werden, sobald die Zukunft abgeschlossen ist) haben ihren eigenen Handler (notifyLateListener).