publicvoidexecute(Runnable command){//任务为空，抛异常if(command == null)thrownewNullPointerException();//返回包含线程数和线程池状态的Integer类型数值int c = ctl.get();//如果工作线程小于核心线程数，创建线程任务并执行if(workerCountOf(c)< corePoolSize){//if(addWorker(command,true))return;//如果创建失败，防止外部已经在线程池中加入新任务，重新获取一遍
c = ctl.get();}//如果线程池是RUNNING状态且任务加入队列成功if(isRunning(c)&& workQueue.offer(command)){//防止外部已经在线程池中加入新任务，重新获取一遍，坚持一遍int recheck = ctl.get();//如果线程池不是RUNNING状态，则将刚加入的任务从队列中移除，并执行拒绝策略if(!isRunning(recheck)&&remove(command))reject(command);//如果之前的线程已经被消费完了，新建一个线程elseif(workerCountOf(recheck)==0)addWorker(null,false);}//核心线程和队列都满了，尝试创建一个新线程elseif(!addWorker(command,false))//创建失败则唤醒拒绝策略reject(command);}
ThreadPoolExecutor.addWorker()方法源码
/**
* 根据当前线程池状态与给定的界限（核心线程数和最大线程数），检查是否可以添加新的任务线程。如果可以则创建并启动任务
* 创建成功返回true，失败返回false；返回false的两种情况
* 1.为线程池状态为STOP或可以关闭即不是RUNNING状态
* 2.线程工厂创建新的任务线程失败
* @param firstTask 新线程应首先运行的任务
* @param core 新增线程时的判断指标
* true：判断当前 RUNNING 状态的线程是否小于corePoolSize
* false：判断当前 RUNNING 状态的线程是否小于maximumPoolSize
*/privatebooleanaddWorker(Runnable firstTask,boolean core){//随机定义的一个字符串，使用break retry时让代码跳出循环且不再进入循环，//使用continue retry时，跳出当前循环进入下一次循环
retry:for(;;){int c = ctl.get();int rs =runStateOf(c);// Check if queue empty only if necessary.// 1. 当线程池的状态大于SHUTDOWN时，返回false。因为线程池处于关闭状态了，就不能再接受任务了// 2. 当线程池的状态是STOP及之上的状态，firstTask不为空或者任务队列为空，返回falseif(rs >= SHUTDOWN &&!(rs == SHUTDOWN &&
firstTask == null &&! workQueue.isEmpty()))returnfalse;for(;;){//获取工作线程数int wc =workerCountOf(c);// 1. 线程数大于等于理论上的最大数(2^29-1)，则直接返回false。（因为超过最大允许线程数会影响左边3位的线程池状态值）// 2. 根据core来决定线程数应该和谁比较。当线程数大于核心线程数或者最大线程数时，直接返回false。// （因为当大于核心线程数时，表示此时任务应该直接添加到队列中(如果队列满了，可能入队失败)；当大于最大线程数时，肯定不能再新创建线程了）if(wc >= CAPACITY ||
wc >=(core ? corePoolSize : maximumPoolSize))returnfalse;//将当前活动线程数+1if(compareAndIncrementWorkerCount(c))break retry;//因为线程池状态和工作线程数是随时可变的，所以要经常提取这个最新值，并将其与前面获取到的值比较，// 如果相同，说明线程池的状态没有发生变化，继续在内循环中进行循环// 如果不相同，说明在这期间，线程池的状态发生了变化，需要跳到外层循环，然后再重新进行循环
c = ctl.get();// Re-read ctlif(runStateOf(c)!= rs)continue retry;// else CAS failed due to workerCount change; retry inner loop// 否则CAS由于workerCount更改而失败；重试内部循环}}boolean workerStarted =false;boolean workerAdded =false;
Worker w = null;try{// 创建一个新的worker线程
w =newWorker(firstTask);final Thread t = w.thread;if(t != null){//在进行ThreadPoolExecutor的敏感操作时，都需要持有锁，避免在添加和自启动线程时被干扰final ReentrantLock mainLock =this.mainLock;
mainLock.lock();try{// Recheck while holding lock.// Back out on ThreadFactory failure or if// shut down before lock acquired.//获取锁时进行重新检查，如果ThreadFactory失败或在获得锁之前关闭，请退回int rs =runStateOf(ctl.get());//如果线程是RUNNING状态或者虽然是关闭状态，但是firstTask是null，就讲worker线程添加到线程池中if(rs < SHUTDOWN ||(rs == SHUTDOWN && firstTask == null)){//检查线程是否是可启动的if(t.isAlive())// precheck that t is startablethrownewIllegalThreadStateException();
workers.add(w);int s = workers.size();//整个线程池在运行期间的最大并发任务个数if(s > largestPoolSize)
largestPoolSize = s;
workerAdded =true;}}finally{
mainLock.unlock();}if(workerAdded){
t.start();
workerStarted =true;}}}finally{if(! workerStarted)addWorkerFailed(w);}return workerStarted;}
工作线程的核心类实现，Worker源码
/**
* 实现Runnable接口，并把本对象作为参数输入给run()方法中的runWorker(this)，
* 所以内部属性线程thread在start的时候，即会调用runWorker方法
*/privatefinalclassWorkerextendsAbstractQueuedSynchronizerimplementsRunnable{/**
* Creates with given first task and thread from ThreadFactory.
* @param firstTask the first task (null if none)
*/Worker(Runnable firstTask){// 它是AbstractQueuedSynchronizer的方法// 在runWorker方法执行之前禁止线程被中断setState(-1);// inhibit interrupts until runWorkerthis.firstTask = firstTask;this.thread =getThreadFactory().newThread(this);}// 当thread被start()之后，执行runWorker方法publicvoidrun(){runWorker(this);}}
