使用Netty編程時，我們經(jīng)常會從用戶線程，而不是Netty線程池發(fā)起write操作，因為我們不能在netty的事件回調中做大量耗時操作。那么問題來了 –

1， writeAndFlush是線程安全的嗎？

2， 是否使用了鎖，導致并發(fā)性能下降呢

?

我們來看代碼 – 在DefaultChannelHandlerContext中

@Overridepublic ChannelFuture writeAndFlush(Object msg, ChannelPromise promise) {DefaultChannelHandlerContext next;next = findContextOutbound(MASK_WRITE);ReferenceCountUtil.touch(msg, next);next.invoker.invokeWrite(next, msg, promise);next = findContextOutbound(MASK_FLUSH);next.invoker.invokeFlush(next);return promise; }

?

在DefaultChannelHandlerInvoker.java中

@Overridepublic void invokeWrite(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) {if (msg == null) {throw new NullPointerException("msg");}if (!validatePromise(ctx, promise, true)) {// promise cancelled ReferenceCountUtil.release(msg);return;}if (executor.inEventLoop()) {invokeWriteNow(ctx, msg, promise);} else {AbstractChannel channel = (AbstractChannel) ctx.channel();int size = channel.estimatorHandle().size(msg);if (size > 0) {ChannelOutboundBuffer buffer = channel.unsafe().outboundBuffer();// Check for null as it may be set to null if the channel is closed alreadyif (buffer != null) {buffer.incrementPendingOutboundBytes(size);}}safeExecuteOutbound(WriteTask.newInstance(ctx, msg, size, promise), promise, msg);}}

?

private void safeExecuteOutbound(Runnable task, ChannelPromise promise, Object msg) {try {executor.execute(task);} catch (Throwable cause) {try {promise.setFailure(cause);} finally {ReferenceCountUtil.release(msg);}}}

?

可見，writeAndFlush如果在Netty線程池內執(zhí)行，則是直接write；否則，將作為一個task插入到Netty線程池執(zhí)行。

?

《Netty權威指南》寫到
通過調用NioEventLoop的execute(Runnable task)方法實現(xiàn)，Netty有很多系統(tǒng)Task，創(chuàng)建他們的主要原因是：當I/O線程和用戶線程同時操作網(wǎng)絡資源時，為了防止并發(fā)操作導致的鎖競爭，將用戶線程的操作封裝成Task放入消息隊列中，由I/O線程負責執(zhí)行，這樣就實現(xiàn)了局部無鎖化。

?

參考
http://www.cnblogs.com/zemliu/p/3667332.html
http://netty.io/5.0/xref/io/netty/channel/DefaultChannelHandlerInvoker.html
http://www.infoq.com/cn/articles/netty-version-upgrade-history-thread-part/

轉載于:https://www.cnblogs.com/Binhua-Liu/p/5295365.html

總結

以上是生活随笔為你收集整理的Netty : writeAndFlush的线程安全及并发问题的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內容還不錯，歡迎將生活随笔推薦給好友。