我们回过头来分析一下Future,在java并发包下就存在了一种异步执行的支持类future,但是由于它的get()方法是阻塞的,所以导致了这个方法在异步处理上存在很大的弊端。
Netty在继承concurrent包下的Future对象的基础上实现了自己的Future。
在并发包下的isDone()方法,不管成功失败与否都会创建一个返回一个完成状态,这样的话,使用者无法知道,该进程到底是成功了还是失败了。
在Netty中对于以上那个问题,创建了一个单独的方法,来判断是否是成功了。
我们可以看到在netty中采用了观察者模式
ChannelFuture ,它进一步继承了Future,多了一个channel()方法,相对来说都是读方法
ChannelPromise有进一步继承了ChannelFuture,增加了写方法
总结:
在netty的ChannelFuture中通过listener来不断监听Future里面的事件,而且listener里面保存了相关channel对象,可以直接通过listener获取相关channel。