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é)果裝回原來(lái)的FutureTask中,后續(xù)直接遍歷集合taskList來(lái)獲取結(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;
}