public class Test {
 //線程池最好作為全局變量, 若作為局部變量記得用完后shutdown()
 ThreadFactory namedThreadFactory = new ThreadFactoryBuilder(）.setNameFormat("thread-start-runner-%d").build();
 ExecutorService taskExe= new ThreadPoolExecutor(10,20,800L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>(100),namedThreadFactory);
 int count=0;
 @Test
 public void test(String[] args) {
  //任務(wù)列表
  List<FutureTask<Integer>> taskList=new ArrayList<FutureTask<Integer>>();
  for(int i=0;i<100;i++){
   //創(chuàng)建100個(gè)任務(wù)放入【任務(wù)列表】
   FutureTask<Integer> futureTask=new FutureTask<Integer>(new Callable<Integer>() {
    @Override
    public Integer call() throws Exception {
     return 1;
    }
   });
   //執(zhí)行的結(jié)果裝回原來的FutureTask中,后續(xù)直接遍歷集合taskList來獲取結(jié)果即可
   taskList.add(futureTask);
   taskExe.submit(futureTask);
  }
  //獲取結(jié)果
  try{
   for(FutureTask<Integer> futureTask:taskList){
                count+=futureTask.get();
            }
  } catch (InterruptedException e) {
   logger.error("線程執(zhí)行被中斷",e);
  } catch (ExecutionException e) {
   logger.error("線程執(zhí)行出現(xiàn)異常",e);
  }
  //關(guān)閉線程池
  taskExe.shutdown();
  //打印: 100
  System.out.println(count);
 }
}

public Future<?> submit(Runnable task) {
 if (task == null) throw new NullPointerException();
 //創(chuàng)建一個(gè)異步執(zhí)行的任務(wù)FutureTask, 【隱患】也在它的run()代碼塊里
 RunnableFuture<Void> ftask = newTaskFor(task, null);
 execute(ftask);
 return ftask;
}