Netty推荐addListener回调异步执行

栏目: Java · 发布时间: 6年前

内容简介:Netty推荐使用addListener的方式来回调异步执行的结果,这种方式优于Future.get,能够更精确地把握异步执行结束的时间。

说明

Netty推荐使用addListener的方式来回调异步执行的结果,这种方式优于Future.get,能够更精确地把握异步执行结束的时间。

错误理解使用addListener的方式

代码如下:

Netty推荐addListener回调异步执行

Netty推荐addListener回调异步执行

代码运行结果:

Netty推荐addListener回调异步执行

疑惑:很疑惑啊,按照上面Netty推荐使用addListener的方式来回调异步执行的结果,这种方式优于Future.get,能够更精确地把握异步执行结束的时间。而且也停顿了5s了,为什么还是顺序执行的呢?

感谢闪电侠、芋艿、晓峰的热心解答。

分析

这段代码 怎么执行都是顺序执行,不阻塞 最后,reactor线程里面都是同步的。

我们来跟踪代码进行查看:

Netty推荐addListener回调异步执行

关键在这里,执行完成write之后返回promise。

Netty推荐addListener回调异步执行

如果是reactor那么就顺序执行,否则就加入队列等待后续执行(如果是顺序的就是等执行完成返回,如果是加入队列就是异步)

这里重点不在writeAndFlush,先分析同步是执行的情况,异步的下面正确方式会分析,如果是同步方式:

Netty推荐addListener回调异步执行

也就是设置了值,之后promise之后返回。

那么:

Netty推荐addListener回调异步执行

Netty推荐addListener回调异步执行

Netty推荐addListener回调异步执行

所有就变成了 java 里面最普通的代码,一个线程代码从上到下执行。也解释了为什么没有走异步情况了。

正确理解使用addListener的方式

不在reactor线程里面执行,就可以做到最开始提到的:Netty推荐使用addListener的方式来回调异步执行的结果,这种方式优于Future.get,能够更精确地把握异步执行结束的时间。

Netty推荐addListener回调异步执行

执行效果如下:

Netty推荐addListener回调异步执行

继续进行分析:

Netty推荐addListener回调异步执行

关键在这里,执行完成write之后返回promise。

Netty推荐addListener回调异步执行

由于是异步直接返回,其实isDone为false,之后addListener就很快添加完成,就执行下面语句了。

Netty推荐addListener回调异步执行

Netty推荐addListener回调异步执行

Netty推荐addListener回调异步执行

这里也可以看到是writeAndFlush执行完成之后调用回调事件,这样才是真正做到了异步执行。

总结

由于之前理解不深刻,感谢 闪电侠、芋艿、晓峰的热心解答 ,现在开朗多了,Netty继续学习中……,希望今天文章对你有所有收获!!!

文章github源代码地址: nettydemo ,或者公号回复“Netty”获取源码地址。


以上所述就是小编给大家介绍的《Netty推荐addListener回调异步执行》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

这就是OKR

这就是OKR

【美】约翰·杜尔(John Doerr) / 曹仰锋、王永贵 / 中信出版社 / 2018-12 / 68.00元

这本书是传奇风险投资人约翰·杜尔的作品,揭示了OKR这一目标设定系统如何促使英特尔、谷歌等科技巨头实现爆炸性增长,以及怎样促进所有组织的蓬勃发展。 20世纪70年代,在英特尔担任工程师时,杜尔首次接触到OKR。之后,作为一个风险投资人,杜尔不遗余力地将这一管理智慧,分享给50多家公司和机构,包括谷歌、亚马逊、领英、脸书、比尔及梅琳达·盖茨基金会,甚至摇滚歌手波诺的公益项目。在杜尔的帮助下,任......一起来看看 《这就是OKR》 这本书的介绍吧!

XML 在线格式化
XML 在线格式化

在线 XML 格式化压缩工具

html转js在线工具
html转js在线工具

html转js在线工具

RGB CMYK 转换工具
RGB CMYK 转换工具

RGB CMYK 互转工具