目前java 8 之前的異步并發(fā)編程的API(callable、future、futuretask)，都有一個共同的問題，就是要獲取結(jié)果必須阻塞等待。netty提供了一種通過回調(diào)的方式獲得結(jié)果的辦法：

Future<TGroup> future = businessEG.submit(new Callable<TGroup>() {@Overridepublic TGroup call() throws Exception {//從數(shù)據(jù)庫查詢TGroup group = groupService.getDBTGroupById(gid);targetGroupsHM.put(gid, group);return group;}});future.addListener(new GenericFutureListener<Future<? super TGroup>>() {@Overridepublic void operationComplete(Future<? super TGroup> future) throws Exception {//處理返回的結(jié)果TGroup group = (TGroup) future.get();if (group == null) {byteBuf.release();return;}sendToSingleGroup(group, byteBuf);}});

總結(jié)

以上是生活随笔為你收集整理的通过 netty 实现异步任务回调获取执行结果的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。