固定線程數線程池寫法

// 取得核心數量
final int numberOfCores = Runtime.getRuntime().availableProcessors();
// 阻塞係數（計算型爲0，IO 型爲0~1）
final double blockingCoefficient = 0;
// 計算線程池大小
final int poolSize = (int) (numberOfCores / (1 - blockingCoefficient));

final List<Callable<String>> partitions = new ArrayList<Callable<String>>();

ExecutorService executorPool = Executors.newFixedThreadPool(poolSize);

// 此處循環添加任務
partitions.add(new Callable<String>(){

    public String call() throws Exception {
        // 業務處理
        return "";
    }
});

// 放入線程池
final List<Future<String>> futures=executorPool.invokeAll(partitions);

// 對運行結果進行處理
for(Future<String> future : futures){
    String result=future.get();
}

// 關閉線程池
executorPool.shutdown();