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