/**
 * 兩個(gè)從數(shù)據(jù)庫(kù)查詢(xún)的耗時(shí)任務(wù)
 * @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àn)椴樵?xún)業(yè)務(wù)需要0和1兩個(gè)狀態(tài)去查詢(xún)
                if (finalI == 0) {
                //這里其實(shí)是查詢(xún)數(shù)據(jù)庫(kù)的mapper操作，為了方便演示
                    countList.add("1");
                    countList.add("2");
                    countList.add("3");
                } else {
                //這里其實(shí)是查詢(xún)數(shù)據(jù)庫(kù)的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();
            }
        });
    }
}
//線程池類(lèi)
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：線程最大空閑時(shí)間
     * unit：時(shí)間單位
     * workQueue：線程等待隊(duì)列  四種隊(duì)列 1.ArrayBlockingQueue：有界隊(duì)列，2.SynchronousQueue：同步隊(duì)列，3.LinkedBlockingQueue：無(wú)界隊(duì)列，4.DelayQueue：延時(shí)阻塞隊(duì)列
     * 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方法測(cè)試
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);
}

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