摘要：所以，并不代表線程池就一定立即就能退出，它也可能必須要等待所有正在執(zhí)行的任務(wù)都執(zhí)行完成了才能退出。

本文主要分析java.util.concurrent.ThreadPoolExecutor的實(shí)現(xiàn)原理，首先看它的構(gòu)造函數(shù)：

public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit unit,
                          BlockingQueue workQueue,
                          ThreadFactory threadFactory,
                          RejectedExecutionHandler handler) {
    if (corePoolSize < 0 ||
        maximumPoolSize <= 0 ||
        maximumPoolSize < corePoolSize ||
        keepAliveTime < 0)
        throw new IllegalArgumentException();
    if (workQueue == null || threadFactory == null || handler == null)
        throw new NullPointerException();
    this.corePoolSize = corePoolSize;
    this.maximumPoolSize = maximumPoolSize;
    this.workQueue = workQueue;
    this.keepAliveTime = unit.toNanos(keepAliveTime);
    this.threadFactory = threadFactory;
    this.handler = handler;
}

corePoolSize:線程池中穩(wěn)定保存的線程數(shù)（一開(kāi)始會(huì)小于這個(gè)數(shù)）

maximumPoolSize：線程池中最大線程數(shù)

keepAliveTime and unit：大于最小線程數(shù)的線程空閑后存活時(shí)間

workQueue：用于存放任務(wù)的阻塞隊(duì)列

threadFactory：用于創(chuàng)建線程的工廠類

handler：當(dāng)任務(wù)隊(duì)列滿了且線程數(shù)達(dá)到了最大時(shí)的飽和策略

對(duì)于IO密集型任務(wù)，線程數(shù)一般設(shè)為CPU數(shù)*2，對(duì)于計(jì)算密集型任務(wù)，線程數(shù)一般設(shè)為CPU數(shù)。

當(dāng)調(diào)用execute方法時(shí)：

public void execute(Runnable command) {
    if (command == null)
        throw new NullPointerException();
    /*
     * Proceed in 3 steps:
     *
     * 1. If fewer than corePoolSize threads are running, try to
     * start a new thread with the given command as its first
     * task.  The call to addWorker atomically checks runState and
     * workerCount, and so prevents false alarms that would add
     * threads when it shouldn"t, by returning false.
     *
     * 2. If a task can be successfully queued, then we still need
     * to double-check whether we should have added a thread
     * (because existing ones died since last checking) or that
     * the pool shut down since entry into this method. So we
     * recheck state and if necessary roll back the enqueuing if
     * stopped, or start a new thread if there are none.
     *
     * 3. If we cannot queue task, then we try to add a new
     * thread.  If it fails, we know we are shut down or saturated
     * and so reject the task.
     */
    int c = ctl.get();
    if (workerCountOf(c) < corePoolSize) {
        if (addWorker(command, true))
            return;
        c = ctl.get();
    }
    if (isRunning(c) && workQueue.offer(command)) {
        int recheck = ctl.get();
        if (! isRunning(recheck) && remove(command))
            reject(command);
        else if (workerCountOf(recheck) == 0)
            addWorker(null, false);
    }
    else if (!addWorker(command, false))
        reject(command);
}

其流程如圖：

創(chuàng)建線程是通過(guò)addWorker創(chuàng)建內(nèi)部Worker類，其中調(diào)用getThreadFactory().newThread(this)來(lái)創(chuàng)建執(zhí)行自己的線程，之后在addWorker中start該線程，執(zhí)行Worker run方法中的runWorker會(huì)不斷的從任務(wù)隊(duì)列中獲取任務(wù)或阻塞，并且每次執(zhí)行任務(wù)前會(huì)執(zhí)行beforeExecute，之后會(huì)afterExecute，可以通過(guò)重寫beforeExecute方法來(lái)給執(zhí)行線程重命名。

線程池狀態(tài)變化如圖：

RUNNING: Accept new tasks and process queued tasks

SHUTDOWN: Don"t accept new tasks, but process queued tasks

STOP: Don"t accept new tasks, don"t process queued tasks, and interrupt in-progress tasks

TIDYING: All tasks have terminated, workerCount is zero, the thread transitioning to state TIDYING will run the terminated() hook method

TERMINATED: terminated() has completed

shutdownNow終止線程的方法是通過(guò)調(diào)用Thread.interrupt()方法來(lái)實(shí)現(xiàn)的:

 * 
 If this thread is blocked in an invocation of the {@link
 * Object#wait() wait()}, {@link Object#wait(long) wait(long)}, or {@link
 * Object#wait(long, int) wait(long, int)} methods of the {@link Object}
 * class, or of the {@link #join()}, {@link #join(long)}, {@link
 * #join(long, int)}, {@link #sleep(long)}, or {@link #sleep(long, int)},
 * methods of this class, then its interrupt status will be cleared and it
 * will receive an {@link InterruptedException}.
 *
 * 
 If this thread is blocked in an I/O operation upon an {@link
 * java.nio.channels.InterruptibleChannel InterruptibleChannel}
 * then the channel will be closed, the thread"s interrupt
 * status will be set, and the thread will receive a {@link
 * java.nio.channels.ClosedByInterruptException}.
 *
 * 
 If this thread is blocked in a {@link java.nio.channels.Selector}
 * then the thread"s interrupt status will be set and it will return
 * immediately from the selection operation, possibly with a non-zero
 * value, just as if the selector"s {@link
 * java.nio.channels.Selector#wakeup wakeup} method were invoked.
 *
 * 
 If none of the previous conditions hold then this thread"s interrupt
 * status will be set. 

可以看到如果線程處于正?；顒?dòng)狀態(tài)，那么會(huì)將該線程的中斷標(biāo)志設(shè)置為true，而無(wú)法中斷當(dāng)前的線程。所以，shutdownNow并不代表線程池就一定立即就能退出，它也可能必須要等待所有正在執(zhí)行的任務(wù)都執(zhí)行完成了才能退出。