到达这一步可能情况为线程池正在关闭或者任务队列已满导致任务提交失败，这里统一进行创建新任务线程处理，创建失败则拒绝任务。
　　其中，addWorker主要分为两部分逻辑：1）修改状态字以增加任务线程数；2）启动任务线程。代码并不复杂，感兴趣的同学可以看下其实现，这里不再赘述。
　　任务线程运行逻辑
　　任务线程（Worker）的主要运行逻辑代码如下：
final void runWorker(Worker w) {
Thread wt = Thread.currentThread();
Runnable task = w.firstTask;
w.firstTask = null;
w.unlock();
boolean completedAbruptly = true;
try {
while (task != null || (task = getTask()) != null) {
w.lock();
if ((runStateAtLeast(ctl.get()， STOP) ||
(Thread.interrupted() &&
runStateAtLeast(ctl.get()， STOP))) &&
!wt.isInterrupted())
wt.interrupt();
try {
beforeExecute(wt， task);
Throwable thrown = null;
try {
task.run();
} catch (RuntimeException x) {
thrown = x; throw x;
} catch (Error x) {
thrown = x; throw x;
} catch (Throwable x) {
thrown = x; throw new Error(x);
} finally {
afterExecute(task， thrown);
}
} finally {
task = null;
w.completedTasks++;
w.unlock();
}
}
completedAbruptly = false;
} finally {
processWorkerExit(w， completedAbruptly);
}
}
　　这里可以看到，任务线程一直通过 getTask() 来获取任务并执行，直到获取任务失败返回null退出当前线程。
　　而getTask实现如下：
private Runnable getTask() {
boolean timedOut = false;
for (;;) {
int c = ctl.get();
int rs = runStateOf(c);
if (rs >= SHUTDOWN && (rs >= STOP || workQueue.isEmpty())) {
decrementWorkerCount();
return null;
}
int wc = workerCountOf(c);
boolean timed = allowCoreThreadTimeOut || wc > corePoolSize;
if ((wc > maximumPoolSize || (timed && timedOut))
&& (wc > 1 || workQueue.isEmpty())) {
if (compareAndDecrementWorkerCount(c))
return null;
continue;
}
try {
Runnable r = timed ?
workQueue.poll(keepAliveTime， TimeUnit.NANOSECONDS) :
workQueue.take();
if (r != null)
return r;
timedOut = true;
} catch (InterruptedException retry) {
timedOut = false;
}
}
}
　　getTask方法返回null时，任务线程会退出。现在我们一步步分析其逻辑：
　　如果线程池正在关闭则返回null。
　　当前线程数为如下情形时返回null：1）大于maximumPoolSize；2）大于corePoolSize并且空闲时间超过keepAliveTime；3）设置了allowCoreThreadTimeOut并且当前空闲时间超过keepAliveTime。注意的是，由于存在并发情况，这里做了后一层检查，即如果当前线程为后一个线程且任务队列非空那么会再次获取任务以执行完任务队列里的任务。
　　通过workQueue.poll()或者workQueue.take()来阻塞获取任务，这两种方法区别在于：前者为等待有间，后者为无限等待。有限等待的情况为，当前任务线程数大于corePoolSize或者设置了allowCoreThreadTimeOut。
　　总结
　　本文分析了ThreadPoolExecutor的使用参数以及内部实现，其实现比较简单，感兴趣的同学可以看下其源码:)