Netty Channel.write線程安全嗎？

我有一個Netty應用程序，我想讓多個線程寫入一個頻道。我只是想知道Channel.write是否是線程安全的？Netty Channel.write線程安全嗎？

來源

2012-06-19 Tarandeep Gill

http://stackoverflow.com/a/10702210/828625 –

我不知道，我可能是錯的。但是這個http://lists.jboss.org/pipermail/netty-users/2008-November/000045.html似乎與您引用的線索中的評論相沖突。 –

同樣，你所鏈接的是同樣的東西，並回答你的問題。 Channel.write是線程安全的。 –

它是線程安全的，所以你不必擔心。

來源

2012-06-19 09:25:48

不，它是線程不安全的，因爲Channel.write在其管道的HeadContext中調用ChannelOutboundBuffer.addMessage，而ChannelOutboundBuffer.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); 
}

來源

2015-07-31 06:00:17 yuguoliang

所以你應該在任何時候至多有一個線程調用Channel.write。代碼格式有問題，您可以在http://netty.io/4.0/xref/index.html – yuguoliang

上找到它。我無法確認您的聲明。我看到'AbstractChannel.write'調用了'Pipeline.write'，它在獲取該通道的事件循環後最終調用'AbstractUnsafe.write'。在這個方法裏面有一個斷言，線程在事件循環內部，所以它一次只能被1個線程調用 – Ferrybig

正如你可以從代碼中看到，該ChannelOutboundBuffer.addMessage()方法本身不是線程安全的。但是，寫入通道是「線程安全的」，因爲netty在單個I/O線程中執行寫入任務/方法。

來源

2015-12-17 09:01:42

Netty Channel.write線程安全嗎？

回答

相關問題