Netty推荐使用addListener的方式来回调异步执行的结果,这种方式优于Future.get,能够更精确地把握异步执行结束的时间。
疑惑:很疑惑啊,按照上面Netty推荐使用addListener的方式来回调异步执行的结果,这种方式优于Future.get,能够更精确地把握异步执行结束的时间。而且也停顿了5s了,为什么还是顺序执行的呢?
我们来跟踪代码进行查看:
关键在这里,执行完成write之后返回promise。
这里重点不在writeAndFlush,先分析同步是执行的情况,异步的下面正确方式会分析,如果是同步方式:
也就是设置了值,之后promise之后返回。
那么:
所有就变成了java里面最普通的代码,一个线程代码从上到下执行。也解释了为什么没有走异步情况了。
不在reactor线程里面执行,就可以做到最开始提到的:Netty推荐使用addListener的方式来回调异步执行的结果,这种方式优于Future.get,能够更精确地把握异步执行结束的时间。
继续进行分析:
关键在这里,执行完成write之后返回promise。
这里也可以看到是writeAndFlush执行完成之后调用回调事件,这样才是真正做到了异步执行。
由于之前理解不深刻,感谢 闪电侠、芋艿、晓峰的热心解答 ,现在开朗多了,Netty继续学习中……,希望今天文章对你有所有收获!!!
文章github源代码地址: nettydemo ,或者公号回复“Netty”获取源码地址。