/**
 * 兩個從數據庫查詢的耗時任務
 * @param countDownLatch
 * @param all
 */
public static void testCount(CountDownLatch countDownLatch, List<String> all) {
    for (int i = 0; i < 2; i++) {
        int finalI = i;
        ThreadPoolFactory.getGeneral().execute(() -> {
            try {
                List<String> countList = new ArrayList<>();
                //這里之所以用for循環(huán)，是因為查詢業(yè)務需要0和1兩個狀態(tài)去查詢
                if (finalI == 0) {
                //這里其實是查詢數據庫的mapper操作，為了方便演示
                    countList.add("1");
                    countList.add("2");
                    countList.add("3");
                } else {
                //這里其實是查詢數據庫的mapper操作，為了方便演示
                    countList.add("5");
                    countList.add("6");
                    countList.add("7");
                    countList.add("8");
                }
                if (countList != null) {
                    all.addAll(countList);
                }
            } catch (Exception ex) {
                ex.printStackTrace();
            } finally {
                countDownLatch.countDown();
            }
        });
    }
}
//線程池類
public class ThreadPoolFactory {
    private static final Logger logger = LoggerFactory.getLogger(ThreadPoolFactory.class);
    private static final ThreadFactory GENERAL_THREAD_FACTORY = new ThreadFactoryBuilder().setNameFormat("general-pool-%d").build();
    /**
     * corePoolSize：核心線程池大小
     * maximumPoolSize：最大線程池大小
     * keepAliveTime：線程最大空閑時間
     * unit：時間單位
     * workQueue：線程等待隊列  四種隊列 1.ArrayBlockingQueue：有界隊列，2.SynchronousQueue：同步隊列，3.LinkedBlockingQueue：無界隊列，4.DelayQueue：延時阻塞隊列
     * threadFactory：線程創(chuàng)建工廠
     * handler：拒絕策略 四種策略 1.ThreadPoolExecutor.AbortPolicy()：2.ThreadPoolExecutor.CallerRunsPolicy()：3.ThreadPoolExecutor.DiscardOldestPolicy()：4.ThreadPoolExecutor.DiscardPolicy()
     */
    private static final ExecutorService GENERAL = new ThreadPoolExecutor(5, 10,
            30L, TimeUnit.MILLISECONDS,
            new LinkedBlockingQueue<>(4096), GENERAL_THREAD_FACTORY, new ThreadPoolExecutor.AbortPolicy());
    public static ExecutorService getGeneral() {
        return GENERAL;
    }
}
//main方法測試
public static void main(String[] args) throws Exception {
    List<String> all = new ArrayList<>();
    CountDownLatch countDownLatch = new CountDownLatch(2);
    testCount(countDownLatch,all);
    countDownLatch.await(10, TimeUnit.SECONDS);
    System.out.println(all);
}

對于上面CountDownLatch不了解的的可以看下我歷史的文章：干貨！CountDownLatch的使用場景

看到這里不知道你們能否看出端倪，先說問題結果吧，最后的這個all集合為空，生產上的接口也是同樣的問題，我上面的代碼是和生產上的1:1復制的偽代碼。

我先說下我的排查思路：

1、線程池問題，我認為是線程沒有被及時的回收，時間太長，并發(fā)數過高，導致線程不夠用，第一想到的是便是線程數需要增加

2、數據庫數據過多，導致查詢比以前慢出一個量級，最后隊列阻塞，拖垮線程（這個概率比較低，因為數據庫查詢很快返回，并沒有需要優(yōu)化的慢sql）

3、懷疑是這個循環(huán)造成的，比如某種機制少循環(huán)或者不循環(huán)，去掉for循環(huán)依然沒解決問題

驗證第一位”間諜“

首先擴大核心線程數和最大線程數，將這倆參數擴大為10和20

private static final ExecutorService GENERAL = new ThreadPoolExecutor(10, 20,
            30L, TimeUnit.MILLISECONDS,
            new LinkedBlockingQueue<>(4096), GENERAL_THREAD_FACTORY, new ThreadPoolExecutor.AbortPolicy());

擴大之后，放上去能查出數據了，感覺解決了這個大問題

那句話怎么說來著，真相往往不是那么的容易發(fā)現(xiàn)，最先抓到的都是小魚小蝦，果不其然，運行了一周左右，同樣的問題又出現(xiàn)了，感覺這就是一水缸，你把水缸變大，終有蓄滿的一天。我們都知道，線程池可不是越大越好。

那么真相究竟是什呢，看到這里的小伙伴如果你已經有了答案，可以先去評論區(qū)評論，不要看下面的答案。