java - Netty Channel.write はスレッドセーフですか?

Question

複数のスレッドをチャネルに書き込みたい Netty アプリがあります。Channel.write がスレッドセーフかどうか疑問に思っていましたか?

Answer 1

コードからわかるように、ChannelOutboundBuffer.addMessage()メソッド自体はスレッド セーフではありません。ただし、netty は単一の I/O スレッドで書き込みタスク/メソッドを実行するため、書き込みチャネルは「スレッドセーフ」です。

Answer 2

スレッドセーフなので、心配する必要はありません。

Answer 3

いいえ、パイプラインの HeadContext でChannel.write呼び出すため、これはスレッドセーフではなく、間違いなくスレッドセーフではありません。このコードを見てください：ChannelOutboundBuffer.addMessageChannelOutboundBuffer.addMessage

 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);
 }