public class Executors {
	public static ExecutorService newFixedThreadPool(int nThreads) {
        	return new ThreadPoolExecutor(nThreads, nThreads,
                             	         0L, TimeUnit.MILLISECONDS,
                            	          new LinkedBlockingQueue<Runnable>());
  	  }
    public static ExecutorService newCachedThreadPool() {
        return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                      60L, TimeUnit.SECONDS,
                                      new SynchronousQueue<Runnable>());
    }
    public static ExecutorService newSingleThreadExecutor() {
        return new FinalizableDelegatedExecutorService
            (new ThreadPoolExecutor(1, 1,
                                    0L, TimeUnit.MILLISECONDS,
                                    new LinkedBlockingQueue<Runnable>()));
    }
    public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) {
        return new ScheduledThreadPoolExecutor(corePoolSize);
    }

    public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> 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;
    }
}

// 構(gòu)造器一
    public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue) {
        this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
        Executors.defaultThreadFactory(), defaultHandler);
    }
	// 構(gòu)造器二
    public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue,
                              ThreadFactory threadFactory) {
        this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
             threadFactory, defaultHandler);
    }
	// 構(gòu)造器三
    public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue,
                              RejectedExecutionHandler handler) {
        this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
             Executors.defaultThreadFactory(), handler);
    }

//創(chuàng)建一個(gè)可緩存的線程池
        ExecutorService cachedThreadPool= Executors.newCachedThreadPool();
        //通過(guò)execute方法執(zhí)行接口
        cachedThreadPool.execute(()->{
            //Runnable to do something.
        });

        ExecutorService threadPool = new ThreadPoolExecutor(// 自定義一個(gè)線程池
                1, // 核心線程數(shù)
                2, // 最大線程數(shù)
                60, // 超過(guò)核心線程數(shù)的額外線程存活時(shí)間
                TimeUnit.SECONDS, // 線程存活時(shí)間的時(shí)間單位
                new ArrayBlockingQueue<>(3) // 有界隊(duì)列，容量是3個(gè)
                , Executors.defaultThreadFactory()    // 線程工廠
                , new ThreadPoolExecutor.AbortPolicy() //線程的拒絕策略
        );
        //執(zhí)行一個(gè)任務(wù)
        threadPool.execute(()->{
            //線程執(zhí)行的具體邏輯
            //Runnable to do something.
        });

    public void execute(Runnable command) {
        if (command == null)
            throw new NullPointerException();
        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);
    }

    private boolean addWorker(Runnable firstTask, boolean core) {
     	// 外層循環(huán)，負(fù)責(zé)判斷線程池狀態(tài)，處理線程池狀態(tài)變量加1操作
        retry:
        for (;;) {
		    // 狀態(tài)總體相關(guān)值：運(yùn)行狀態(tài) + 執(zhí)行線程任務(wù)數(shù)量 
            int c = ctl.get();
			// 讀取狀態(tài)值 - 運(yùn)行狀態(tài)
            int rs = runStateOf(c);
            // Check if queue empty only if necessary.
			// 滿足下面兩大條件的，說(shuō)明線程池不能接受任務(wù)了，直接返回false處理
			// 主要目的就是想說(shuō)，只有線程池的狀態(tài)為 RUNNING 狀態(tài)時(shí)，線程池才會(huì)接收
			// 新的任務(wù)，增加新的Worker工作線程
			// 線程池的狀態(tài)已經(jīng)至少已經(jīng)處于不能接收任務(wù)的狀態(tài)了
            if (rs >= SHUTDOWN &&
			  //目的是檢查線 程池是否處于關(guān)閉狀態(tài)
                ! (rs == SHUTDOWN && firstTask == null && ! workQueue.isEmpty()))
                       return false;
				// 內(nèi)層循環(huán)，負(fù)責(zé)worker數(shù)量加1操作
				for (;;) {
				// 獲取當(dāng)前worker線程數(shù)量
					int wc = workerCountOf(c);
					if (wc >= CAPACITY ||
						// 如果線程池?cái)?shù)量達(dá)到最大上限值CAPACITY
						// core為true時(shí)判斷是否大于corePoolSize核心線程數(shù)量
						// core為false時(shí)判斷是否大于maximumPoolSize最大設(shè)置的線程數(shù)量
						wc >= (core ? corePoolSize : maximumPoolSize))
						return false;
					// 調(diào)用CAS原子操作，目的是worker線程數(shù)量加1
					if (compareAndIncrementWorkerCount(c)) //
						break retry;
					c = ctl.get();  // Re-read ctl
					// CAS原子操作失敗的話，則再次讀取ctl值
					if (runStateOf(c) != rs)
					// 如果剛剛讀取的c狀態(tài)不等于先前讀取的rs狀態(tài)，則繼續(xù)外層循環(huán)判斷
						continue retry;
					// else CAS failed due to workerCount change; retry inner loop
					// 之所以會(huì)CAS操作失敗，主要是由于多線程并發(fā)操作，導(dǎo)致workerCount
					// 工作線程數(shù)量改變而導(dǎo)致的，因此繼續(xù)內(nèi)層循環(huán)嘗試操作
				}
        }
        boolean workerStarted = false;
        boolean workerAdded = false;
        Worker w = null;
        try {
			// 創(chuàng)建一個(gè)Worker工作線程對(duì)象，將任務(wù)firstTask，
			// 新創(chuàng)建的線程thread都封裝到了Worker對(duì)象里面
            w = new Worker(firstTask);
            final Thread t = w.thread;
            if (t != null) {
				// 由于對(duì)工作線程集合workers的添加或者刪除，
				// 涉及到線程安全問(wèn)題，所以才加上鎖且該鎖為非公平鎖
                final ReentrantLock mainLock = this.mainLock;
                mainLock.lock();
                try {
                    // Recheck while holding lock.
                    // Back out on ThreadFactory failure or if
                    // shut down before lock acquired.
					// 獲取鎖成功后，執(zhí)行臨界區(qū)代碼，首先檢查獲取當(dāng)前線程池的狀態(tài)rs
                    int rs = runStateOf(ctl.get());
					// 當(dāng)線程池處于可接收任務(wù)狀態(tài)
					// 或者是不可接收任務(wù)狀態(tài)，但是有可能該任務(wù)等待隊(duì)列中的任務(wù)
					// 滿足這兩種條件時(shí)，都可以添加新的工作線程
                    if (rs < SHUTDOWN ||
                        (rs == SHUTDOWN && firstTask == null)) {
                        if (t.isAlive()) // precheck that t is startable
                            throw new IllegalThreadStateException();
                         workers.add(w);
						// 添加新的工作線程到工作線程集合workers，workers是set集合
                        int s = workers.size();
                        if (s > largestPoolSize) 
						// 變量記錄了線程池在整個(gè)生命周期中曾經(jīng)出現(xiàn)的最大線程個(gè)數(shù)
                            largestPoolSize = s;
                        workerAdded = true;
                    }
                } finally {
                    mainLock.unlock();
                }
                if (workerAdded) { 
				// 往workers工作線程集合中添加成功后，則立馬調(diào)用線程start方法啟動(dòng)起來(lái)
                    t.start();
                    workerStarted = true;
                }
            }
        } finally {
            if (! workerStarted)
			// 如果啟動(dòng)線程失敗的話，還得將剛剛添加成功的線程共集合中移除并且做線				// 程數(shù)量做減1操作
                addWorkerFailed(w);
        }
        return workerStarted;
    }

    final void runWorker(Worker w) {
        Thread wt = Thread.currentThread();
        Runnable task = w.firstTask;
        w.firstTask = null;
		// allow interrupts 允許中斷
        w.unlock();
        boolean completedAbruptly = true;
        try {
			// 不斷從等待隊(duì)列blockingQueue中獲取任務(wù)
			// 之前addWorker(null, false)這樣的線程執(zhí)行時(shí)，
			// 會(huì)通過(guò)getTask中再次獲取任務(wù)并執(zhí)行
            while (task != null || (task = getTask()) != null) {
                w.lock(); 
				// 上鎖，并不是防止并發(fā)執(zhí)行任務(wù)，
				// 而是為了防止shutdown()被調(diào)用時(shí)不終止正在運(yùn)行的worker線程
                // If pool is stopping, ensure thread is interrupted;
                // if not, ensure thread is not interrupted.  This
                // requires a recheck in second case to deal with
                // shutdownNow race while clearing interrupt
                if ((runStateAtLeast(ctl.get(), STOP) ||
                     (Thread.interrupted() &&
                      runStateAtLeast(ctl.get(), STOP))) &&
                    !wt.isInterrupted())
                    wt.interrupt();
                try {
					// task.run()執(zhí)行前，由子類實(shí)現(xiàn)
                    beforeExecute(wt, task);
                    Throwable thrown = null;
                    try {
                        task.run(); // 執(zhí)行線程Runable的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 {
						// task.run()執(zhí)行后，由子類實(shí)現(xiàn)
                        afterExecute(task, thrown);
                    }
                } finally {
                    task = null;
                    w.completedTasks++;
                    w.unlock();
                }
            }
            completedAbruptly = false;
        } finally {
            processWorkerExit(w, completedAbruptly);
        }
    }

        threadPool.shutdown();
        threadPool.shutdownNow();