Il thread Netty Channel.write è sicuro?

Question

Ho un'app Netty, dove voglio avere più di un thread per scrivere su un canale. Mi stavo chiedendo se Channel.write è thread-safe?

Answer 1

È thread-safe, quindi non devi preoccuparti.

Answer 2

No, è thread-safe, perché Channel.write chiama ChannelOutboundBuffer.addMessage nel suo HeadContext della pipeline e ChannelOutboundBuffer.addMessage è sicuramente thread-safe. Date un'occhiata a questo codice:

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

Come si può vedere dal codice, il metodo ChannelOutboundBuffer.addMessage() in sé non è thread-safe. Tuttavia, il canale Writing è "thread safe" perché netty esegue il task/metodo write nel singolo thread I/O.