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; }