Runtime.getRuntime().addShutdownHook(new Thread(() -> {
    try {
        executorService.shutdown();
        while(!executorService.awaitTermination(10,TimeUnit.SECONDS)) {}
    } catch(Exception e) {
    }
}));

/**
 * @param corePoolSize the number of threads to keep in the pool, even
 *           if they are idle, unless {@code allowCoreThreadTimeOut} is set
 *        核心線程數(shù)：即使是空閑狀態(tài)也可以在線程池存活的線程數(shù)量，除非           
 *        allowCoreThreadTimeOut 設(shè)置為 true。
 * @param keepAliveTime when the number of threads is greater than
 *        the core, this is the maximum time that excess idle threads
 *        will wait for new tasks before terminating.
 *         存活時(shí)間：對(duì)于超出核心線程數(shù)的線程，空閑時(shí)間一旦達(dá)到存活時(shí)間，就會(huì)被銷毀。
 */
public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit unit,
                          BlockingQueue<Runnable> workQueue,
                          ThreadFactory threadFactory,
                           RejectedExecutionHandler handler) { ... ... }

ThreadPoolExecutor executor = new ThreadPoolExecutor(0, 5,
                30L, TimeUnit.SECONDS, new LinkedBlockingQueue<>(15));
for (int i = 0; i < 20; i++) {
    executor.execute(() -> {
        // 簡(jiǎn)單地打印當(dāng)前線程名稱
        System.out.println(Thread.currentThread().getName());
    });
}

public class Executors {
    ... ...
    public static ExecutorService newCachedThreadPool() {
            return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                          60L, TimeUnit.SECONDS,
                                          new SynchronousQueue<Runnable>());
    }
    ... ...
}

public void allowCoreThreadTimeOut(boolean value) {
    // 核心線程存活時(shí)間必須大于0，一旦開(kāi)啟，keepAliveTime 也必須大于0
    if (value && keepAliveTime <= 0)
        throw new IllegalArgumentException("Core threads must have nonzero keep alive times");
    // 將 allowCoreThreadTimeOut 值設(shè)為傳入的參數(shù)值
    if (value != allowCoreThreadTimeOut) {
        allowCoreThreadTimeOut = value;
        // 開(kāi)啟后，清理所有的超時(shí)空閑線程，包括核心線程
        if (value)
            interruptIdleWorkers();
    }
}

ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 5,
                30L, TimeUnit.SECONDS, new LinkedBlockingQueue<>(15));
executor.allowCoreThreadTimeOut(true);
for (int i = 0; i < 20; i++) {
            executor.execute(() -> {
               // 簡(jiǎn)單地打印當(dāng)前線程名稱
                System.out.println(Thread.currentThread().getName());
            });
}

ThreadPoolExecutor executor2 = new ThreadPoolExecutor(1, 5, 30, TimeUnit.SECONDS,
            new ArrayBlockingQueue<Runnable>(150),
            new ThreadFactory() { 
                public Thread newThread(Runnable r) {
                    Thread thread = new Thread(r, r.hashCode()+"");
                    thread.setDaemon(true);//設(shè)置成守護(hù)線程
                    return thread;
                }
            }
);
for (int i = 0; i < 20; i++) {
            executor2.execute(() -> {
               // 簡(jiǎn)單地打印當(dāng)前線程名稱
                System.out.println(Thread.currentThread().getName());
            });
}