Netty Channel.write iş parçacığı güvenli mi?

Question

Bir kanala yazacak birden fazla ileti dizisine sahip olmak istediğim bir Netty uygulamasına sahibim. Sadece Channel.write iş parçacığı güvenli olup olmadığını merak ediyordum?

Answer 1

Bu iş parçacığı güvenlidir, bu nedenle endişelenmeniz gerekmez.

Answer 2

Hayır, iş parçacığının güvensiz olması nedeniyle, Channel.write, boru hattının HeadContext'inde ChannelOutboundBuffer.addMessage ve ChannelOutboundBuffer.addMessage kesinlikle iş parçacığı için güvenli değildir. kod görebileceğiniz gibi

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

, ChannelOutboundBuffer.addMessage() yöntem kendisi parçacığı güvenli değil: Bu kod bir bakın. Bununla birlikte, yazma kanalı "iş parçacığı güvenli" dir, çünkü netty tek G/Ç iş parçasındaki yazma görevini/yöntemini çalıştırır.