Czy wątek Netty Channel.write jest bezpieczny?

Question

Mam aplikację Netty, w której chcę mieć więcej niż jeden wątek do zapisu na kanale. Właśnie zastanawiałem się czy Channel.write jest wątkiem bezpiecznym?

Answer 1

Jest bezpieczny dla wątków, więc nie musisz się martwić.

Answer 2

Nie, jest niebezpieczny dla wątków, ponieważ Channel.write wywołuje ChannelOutboundBuffer.addMessage w swoim HeadContext w jego potoku, a ChannelOutboundBuffer.addMessage jest zdecydowanie wątkowo niebezpieczny. Spojrzeć na ten kod:

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

Jak widać z kodu, sama metoda ChannelOutboundBuffer.addMessage() nie jest bezpieczeństwo wątków. Jednak kanał zapisu jest "bezpieczny dla wątków", ponieważ netty wykonuje zadanie/metodę zapisu w pojedynczym wątku we/wy.