java自带的线程池方法

二、原理分析
　　从上面使用线程池的例子来看，最主要就是两步，构造ThreadPoolExecutor对象，然后每来一个任务，就调用ThreadPoolExecutor对象的execute方法。
　　1、ThreadPoolExecutor结构
　　ThreadPoolExecutor的主要结构及继承关系如下图所示：
　　主要成员变量：任务队列——存放那些暂时无法执行的任务；工作线程池——存放当前启用的所有线程；线程工厂——创建线程；还有一些用来调度线程与任务并保证线程安全的成员。
　　了解了ThreadPoolExecutor的主要结构，再简单梳理一下“一个传入线程池的任务能够被最终正常执行需要经过的主要流程”，方法名称前面没有“XXX.”这种标注的都是ThreadPoolExecutor的方法：
　　2、ThreadPoolExecutor构造器及重要常量
　　简单了解下构造器，ThreadPoolExecutor的四个构造器的源码如下：
　　publicThreadPoolExecutor（ intcorePoolSize， intmaximumPoolSize，longkeepAliveTime，TimeUnit unit，BlockingQueue《Runnable》 workQueue） {this（corePoolSize， maximumPoolSize， keepAliveTime， unit， workQueue，Executors.defaultThreadFactory（）， defaultHandler）; }publicThreadPoolExecutor（ intcorePoolSize， intmaximumPoolSize，longkeepAliveTime，TimeUnit unit，BlockingQueue《Runnable》 workQueue，ThreadFactory threadFactory） { this（corePoolSize， maximumPoolSize， keepAliveTime， unit， workQueue，threadFactory， defaultHandler）; } publicThreadPoolExecutor（ intcorePoolSize，intmaximumPoolSize， longkeepAliveTime，TimeUnit unit，BlockingQueue《Runnable》 workQueue，RejectedExecutionHandler handler） { this（corePoolSize， maximumPoolSize， keepAliveTime， unit， workQueue，Executors.defaultThreadFactory（）， handler）; }publicThreadPoolExecutor（ intcorePoolSize， intmaximumPoolSize，longkeepAliveTime，TimeUnit unit，BlockingQueue《Runnable》 workQueue，ThreadFactory threadFactory，RejectedExecutionHandler handler） { if（corePoolSize 《0||maximumPoolSize 《= 0||maximumPoolSize 《 corePoolSize ||keepAliveTime 《 0）thrownewIllegalArgumentException（）; if（workQueue == null|| threadFactory == null|| handler == null） thrownewNullPointerException（）; this.acc = System.getSecurityManager（） == null？ null:AccessController.getContext（）; this.corePoolSize = corePoolSize;this.maximumPoolSize = maximumPoolSize; this.workQueue = workQueue;this.keepAliveTime = unit.toNanos（keepAliveTime）; this.threadFactory = threadFactory;this.handler = handler; }
　　从源码中可以看出，这四个构造器都是调用最后一个构造器，只是根据开发者传入的参数的不同而填充一些默认的参数。比如如果开发者没有传入线程工厂threadFactory参数，那么构造器就使用默认的Executors.defaultThreadFactor。
　　在这里还要理解ThreadPoolExecutor的几个常量的含义和几个简单方法：
　　//Integer.SIZE是一个静态常量，值为32，也就是说COUNT_BITS是29privatestaticfinalintCOUNT_BITS = Integer.SIZE - 3; //CAPACITY是最大容量536870911，因为1左移29位之后-1，导致最高三位为0，而其余29位全部为1privatestaticfinalintCAPACITY = （ 1《《 COUNT_BITS） - 1; //ctl用于表示线程池状态和有效线程数量，最高三位表示线程池的状态，其余低位表示有效线程数量//初始化之后ctl等于RUNNING的值，即默认状态是运行状态，线程数量为0privatefinalAtomicInteger ctl =newAtomicInteger（ctlOf（RUNNING， 0））; //1110 0000 0000 0000 0000 0000 0000 0000最高三位为111privatestaticfinalintRUNNING = - 1《《 COUNT_BITS; //最高三位为000privatestaticfinalintSHUTDOWN = 0《《 COUNT_BITS; //0010 0000 0000 0000 0000 0000 0000 0000最高三位为001privatestaticfinalintSTOP = 1《《 COUNT_BITS; //0100 0000 0000 0000 0000 0000 0000 0000最高三位为010privatestaticfinalintTIDYING = 2《《 COUNT_BITS; //0110 0000 0000 0000 0000 0000 0000 0000最高三位为011privatestaticfinalintTERMINATED = 3《《 COUNT_BITS; /** * 获取运行状态，入参为ctl。因为CAPACITY是最高三位为0，其余低位为1 * 所以当取反的时候，就只有最高三位为1，再经过与运算，只会取到ctl的最高三位 * 而这最高三位如上文所述，表示线程池的状态 */privatestaticintrunStateOf（ intc） { returnc & ~CAPACITY; } /** * 获取工作线程数量，入参为ctl。因为CAPACITY是最高三位为0，其余低位为1 * 所以当进行与运算的时候，只会取到低29位，这29位正好表示有效线程数量 */privatestaticintworkerCountOf（ intc） { returnc & CAPACITY; } privatestaticintctlOf（ intrs， intwc） { returnrs | wc; } //任务队列，用于存放待执行任务的阻塞队列privatefinalBlockingQueue《Runnable》 workQueue; /** 判断线程池是否是运行状态，传入的参数是ctl的值 * 只有RUNNING的符号位是1，也就是只有RUNNING为负数 * 所以如果目前的ctl值《0，就是RUNNING状态 */privatestaticbooleanisRunning（intc） { returnc 《 SHUTDOWN; } //从任务队列中移除任务publicbooleanremove（Runnable task） { booleanremoved = workQueue.remove（task）; tryTerminate（）; // In case SHUTDOWN and now emptyreturnremoved; }