摘要：目前之前的异步并发编程的，都有一个共同的问题，就是要获取结果必须阻塞等待。提供了一种通过回调的方式获得结果的办法从数据库查询处理返回的结果
目前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);
}
});
文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。
转载请注明本文地址：https://www.ucloud.cn/yun/67496.html
