Java并发编程Callable与Future的应用实例代码
本文主要探究的是java并发编程callable与future的使用，分享了相关实例代码，具体介绍如下。
十载的泸溪网站建设经验，针对设计、前端、开发、售后、文案、推广等六对一服务，响应快，48小时及时工作处理。全网整合营销推广的优势是能够根据用户设备显示端的尺寸不同，自动调整泸溪建站的显示方式，使网站能够适用不同显示终端，在浏览器中调整网站的宽度，无论在任何一种浏览器上浏览网站，都能展现优雅布局与设计，从而大程度地提升浏览体验。创新互联公司从事“泸溪网站设计”,“泸溪网站推广”以来，每个客户项目都认真落实执行。
我们都知道实现多线程有2种方式，一种是继承Thread，一种是实现Runnable，但这2种方式都有一个缺陷，在任务完成后无法获取返回结果。要想获得返回结果，就得使用Callable，Callable任务可以有返回值，但是没法直接从Callable任务里获取返回值；想要获取Callabel任务的返回值，需要用到Future。所以Callable任务和Future模式，通常结合起来使用。
试想一个场景：需要一个帖子列表接口，除了需要返回帖子列表之外，还需要返回每条帖子的点赞列表和评论列表。一页10条帖子来计算，这个接口需要访问21次数据库，访问一次数据库按100ms计算，21次，累计时间为2.1s。这个响应时间，怕是无法令人满意的。怎么办呢？异步化改造接口。
查出帖子列表后，迭代帖子列表，在循环里起10个线程，并发去获取每条帖子的点赞列表，同时另起10个线程，并发去获取每条帖子的评论列表。这样改造之后，接口的响应时间大大缩短，在200ms。这个时候就要用Callabel结合Future来实现。
private List createPostResponseList(Page page,final String userId){
if(page.getCount()==0||page==null||page.getList()==null){
return null;
}
//获取帖子列表
List circleResponseList = page.getList();
int size=circleResponseList.size();
ExecutorService commentPool = Executors.newFixedThreadPool(size);
ExecutorService supportPool = Executors.newFixedThreadPool(size);
try {
List commentFutureList = new ArrayList(size);
if (circleResponseList != null && circleResponseList.size() > 0) {
for (PostResponse postResponse : circleResponseList) {
final String circleId=postResponse.getId();
final String postUserId=postResponse.getUserId();
//查评论列表
Callable> callableComment = new Callable>() {
@Override
public List call() throws Exception {
return circleReviewsBiz.getPostComments(circleId);
}
};
Future f = commentPool.submit(callableComment);
commentFutureList.add(f);
//查点赞列表
Callable> callableSupport = new Callable>() {
@Override
public List call() throws Exception {
return circleZanBiz.findList(circleId);
}
};
Future supportFuture = supportPool.submit(callableSupport);
commentFutureList.add(supportFuture);
}
}
// 获取所有并发任务的执行结果
int i = 0;
PostResponse temp = null;
for (Future f : commentFutureList) {
temp = circleResponseList.get(i);
temp.setCommentList((List) f.get();
temp.setSupportList((List) f.get();
circleResponseList.set(i, temp);
i++;
}
} catch (Exception e) {
e.printStackTrace();
} finally {
// 关闭线程池
commentPool.shutdown();
supportPool.shutdown();
}
return circleResponseList;
}
总结
以上就是本文关于Java并发编程Callable与Future的应用实例代码的全部内容，希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题，如有不足之处，欢迎留言指出。感谢朋友们对本站的支持！
网页名称：Java并发编程Callable与Future的应用实例代码
标题链接：
http://kswjz.com/article/iejgpe.html
扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
