利用ExecutorService建立的執行緒池並行地處理任務，可以節省總的等待時間（總等待時間等於耗時最多的那個任務的耗時）。不過執行緒池不會被自動地釋放。所以要麼建立一次執行緒池之後重複地使用，要麼每次使用完之後顯式地釋放掉。不然的話最終會導致記憶體被用光。 問題現象： 使用Executors建立執行緒池批量並行處理任務（比如請求外部介面），過一段時間之後，jvm報OutOfMemory錯誤，程序死掉。 觀察，通過jstack觀察執行緒數，某些型別的執行緒一直在增長： jstack <pid> | grep "waiting on condition" | wc -l jstack <pid> | grep "waiting on condition"| grep pool |wc -l 問題程式碼（batchProcess不斷被呼叫）：

private void batchProcess(List<Integer> idList) throws Exception {
   ExecutorService executorService = Executors.newFixedThreadPool(idList.size());
   List<AreaThread> taskList = new ArrayList<>();
   for(Integer id : idList){
      taskList.add(new AreaThread(id));
   }

   List<Future<Integer>> futureList = executorService.invokeAll(taskList);

   List<Integer> resultList = new ArrayList<>();
   for(Future<Integer> future : futureList){
      Integer result = future.get();
      logger.debug("result={}", result);
      resultList.add(result);
   }
}
 

原因：executorService 沒有被顯式地關閉，執行緒池建立之後一直在等待新的任務，越積越多。 改正後的程式碼：

private void batchProcess(List<Integer> idList) throws Exception {
   ExecutorService executorService = Executors.newFixedThreadPool(idList.size());
   List<AreaThread> taskList = new ArrayList<>();
   for(Integer id : idList){
      taskList.add(new AreaThread(id));
   }

   List<Future<Integer>> futureList = executorService.invokeAll(taskList);

   List<Integer> resultList = new ArrayList<>();
   for(Future<Integer> future : futureList){
      Integer result = future.get();
      logger.debug("result={}", result);
      resultList.add(result);
   }

   executorService.shutdown(); //如果不shutdown，執行緒池一直不會釋放
}
 

或者：建立一個公用的executorService，讓它一直存在，所有的批量任務都使用它。