Java并发编程Callable与Future的应用实例代码

private List<PostResponse> createPostResponseList(Page<PostResponse> page,final String userId){ 
    if(page.getCount()==0||page==null||page.getList()==null){ 
      return null; 
    } 
    //获取帖子列表 
    List<PostResponse> circleResponseList = page.getList(); 
    int size=circleResponseList.size(); 
    ExecutorService commentPool = Executors.newFixedThreadPool(size); 
    ExecutorService supportPool = Executors.newFixedThreadPool(size); 
    try { 
      List<Future> commentFutureList = new ArrayList<Future>(size); 
      if (circleResponseList != null && circleResponseList.size() > 0) { 
        for (PostResponse postResponse : circleResponseList) { 
          final String circleId=postResponse.getId(); 
          final String postUserId=postResponse.getUserId(); 
          //查评论列表 
          Callable<List<CircleReviews>> callableComment = new Callable<List<CircleReviews>>() { 
            @Override 
            public List<CircleReviews> call() throws Exception { 
              return circleReviewsBiz.getPostComments(circleId); 
            } 
          }; 
          Future f = commentPool.submit(callableComment); 
          commentFutureList.add(f); 
          //查点赞列表 
          Callable<List<CircleZan>> callableSupport = new Callable<List<CircleZan>>() { 
            @Override 
            public List<CircleZan> 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<CircleReviews>) f.get(); 
        temp.setSupportList((List<CircleZan>) f.get(); 
        circleResponseList.set(i, temp); 
        i++; 
      } 
 
    } catch (Exception e) { 
      e.printStackTrace(); 
    } finally { 
      // 关闭线程池 
      commentPool.shutdown(); 
      supportPool.shutdown(); 
    } 
    return circleResponseList; 
}