摘要：目前之前的異步并發(fā)編程的，都有一個共同的問題，就是要獲取結(jié)果必須阻塞等待。提供了一種通過回調(diào)的方式獲得結(jié)果的辦法從數(shù)據(jù)庫查詢處理返回的結(jié)果
目前java 8 之前的異步并發(fā)編程的API(callable、future、futuretask)，都有一個共同的問題，就是要獲取結(jié)果必須阻塞等待。netty提供了一種通過回調(diào)的方式獲得結(jié)果的辦法：
Future future = businessEG.submit(new Callable() {
@Override
public TGroup call() throws Exception {
//從數(shù)據(jù)庫查詢
TGroup group = groupService.getDBTGroupById(gid);
targetGroupsHM.put(gid, group);
return group;
}
});
future.addListener(new GenericFutureListener>() {
@Override
public void operationComplete(Future future) throws Exception {
//處理返回的結(jié)果
TGroup group = (TGroup) future.get();
if (group == null) {
byteBuf.release();
return;
}
sendToSingleGroup(group, byteBuf);
}
});
文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址：http://m.hztianpu.com/yun/67496.html
