Netty推荐addListener回调异步执行

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

内容简介: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回调异步执行》,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对 码农网 的支持!

查看所有标签

猜你喜欢:

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

RESTful Web Services Cookbook

RESTful Web Services Cookbook

Subbu Allamaraju / Yahoo Press / 2010-3-11 / USD 39.99

While the REST design philosophy has captured the imagination of web and enterprise developers alike, using this approach to develop real web services is no picnic. This cookbook includes more than 10......一起来看看 《RESTful Web Services Cookbook》 这本书的介绍吧!

图片转BASE64编码
图片转BASE64编码

在线图片转Base64编码工具

Base64 编码/解码
Base64 编码/解码

Base64 编码/解码