¿Netty Channel.write es seguro?

Question

Tengo una aplicación de Netty, donde quiero tener más de un subproceso para escribir en un canal. Me preguntaba si Channel.write es seguro para subprocesos

Answer 1

Es seguro para subprocesos, por lo que no tiene que preocuparse.

Answer 2

No, es inseguro, porque Channel.write llama a ChannelOutboundBuffer.addMessage en HeadContext de su pipeline, y ChannelOutboundBuffer.addMessage es definitivamente inseguro. Echar un vistazo a este código:

public void addMessage(Object msg, int size, ChannelPromise promise) { 
    Entry entry = Entry.newInstance(msg, size, total(msg), promise); 
    if (tailEntry == null) { 
     flushedEntry = null; 
     tailEntry = entry; 
    } else { 
     Entry tail = tailEntry; 
     tail.next = entry; 
     tailEntry = entry; 
    } 
    if (unflushedEntry == null) { 
     unflushedEntry = entry; 
    } 

    // increment pending bytes after adding message to the unflushed arrays. 
    // See https://github.com/netty/netty/issues/1619 
    incrementPendingOutboundBytes(size, false); 
} 

Answer 3

Como se puede ver en el código, el método ChannelOutboundBuffer.addMessage() sí mismo no es hilo de seguridad. Sin embargo, Writing channel es "thread safe" porque netty ejecuta la tarea/método de escritura en la única cadena de E/S.