JUC(4)---java线程池原理及源码分析

ctl 是对线程池的运行状态和线程池中有效线程的数量进行控制的一个字段， 它包含两部分的信息: 线程池的运行状态 (runState) 和线程池内有效线程的数量 (workerCount)，这里可以看到，使用了Integer类型来保存，高3位保存runState，低29位保存

workerCount。COUNT_BITS 就是29，CAPACITY就是1左移29位减1（29个1），这个常量表示workerCount的上限值，大约是5.3亿。

线程池五种状态：

RUNNING：ctl高三位111，可以接受新任务，并且处理已经添加的任务。线程池的初始化状态就是running。

 

SHUTDOWN：ctl高三位000，不接受新任务，但是可以处理已经添加的任务。调用shutdown()方法，由running变成shutdown

 

STOP：ctl高三位001，不接受新任务，不处理已添加的任务，并且还会中断正在处理的任务。调用shutdownNow()方法，由running/shutdown变成stop

 

TIDYING：ctl高三位010，当所有的任务已终止，ctl记录的任务数量为0，线程池会变为tidying 状态。当线程池变为tidying 状态时，会执行钩子函数terminated()。terminated()在 ThreadPoolExecutor类中是空的，若用户想在线程池变为tidying 时，进行其他处理；可以通过重写terminated()。线程池为shutdown状态，并且阻塞队列是空的，并且执行的任务也是空就会由shutdown变成tidying；stop状态时，线程池中任务为空也会变成tidying

 

TERMINATED：ctl高三位011，线程池彻底凉凉了

当线程池处于tidying状态并且执行完了terminated()方法，就会由tidying变成terminated

 

构造方法：

 

corePoolSize：线程池中的核心线程数，当提交一个任务时，线程池创建一个新线程执行任务，直到当 前线程数等于corePoolSize；如果当前线程数为corePoolSize，继续提交的任务被保存到 阻塞队列中，等待被执行；如果执行了线程池的prestartAllCoreThreads()方法，线程池会 提前创建并启动所有核心线程。

maximumPoolSize：线程池中允许的最大线程数。如果当前阻塞队列满了，且继续提交任务，则创建新的线程执行任务，前提是当前线程数小于maximumPoolSize；

keepAliveTime：线程池维护线程所允许的空闲时间。当线程池中的线程数量大于corePoolSize的时候，如果这时没有新的任务提交，核心线程外的线程不会立即销毁，而是会等待，直到等待的时间超过了keepAliveTime。

unit：keepAliveTime的单位。 

workQueue：用来保存等待被执行的任务的阻塞队列，且任务必须实现Runable接口，在JDK中提供了如下阻塞队列：

　　1、ArrayBlockingQueue：基于数组结构的有界阻塞队列，按FIFO排序任务；

　　 2、LinkedBlockingQuene：基于链表结构的阻塞队列，按FIFO排序任务，

　　3、SynchronousQuene：一个不存储元素的阻塞队列，每个插入操作必须等到另一个线程调用移除操作，否则插入操作一直处于阻塞状态。

　　 4、priorityBlockingQuene：具有优先级的无界阻塞队列；

threadFactory ：ThreadFactory，用来创建新线程。默认使用 Executors.defaultThreadFactory() 来创建线程。使用默认的ThreadFactory来创建线程时，会使新创建的线程具有相同的NORM_PRIORITY优先级并且是非守护线程，同时也设置了线程的名称。

Handler：线程池的拒绝策略，当阻塞队列满了，且没有空闲的工作线程，如果继续提交任务，必须采取一种策略处理该任务，线程池提供了4种策略：

　　1、AbortPolicy：直接抛出异常，默认策略；

　　2、CallerRunsPolicy：用调用者所在的线程来执行任务；

　　3、DiscardOldestPolicy：丢弃阻塞队列中靠最前的任务，并执行当前任务；

　　4、DiscardPolicy：直接丢弃任务；

上面的4种策略都是ThreadPoolExecutor的内部类。 当然也可以根据应用场景实现RejectedExecutionHandler接口，自定义策略。

 

通过execute或者submit向线程池提交任务。任务提交的时候先提交给核心线程（corePoolSize）；如果核心线程满了，就将任务放到workQueue里面去排队等待；如果队列也满了（取决用的什么队列，以及设置的大小），就会将新进来的任务提交给非核心线程，非核心线程数量等于maximumPoolSize - corePoolSize，非核心线程使用之后会被回收。如果非核心线程也满了，那么就执行相应的拒绝策略RejectedExecutionHandler。

 

 

源码解析：

1.execute方法：

 

 

 2. 可以看到关键方法是addWork方法，可以看到在addWork方法先会进行一系列判断，如果都通过了，才会进行任务的创建

 

 3.Worker内部类，这类是继承了AbstractQueuedSynchronizer并且实现了Runable接口，其中还有两个重要属性一个是Thread， 一个是firstTask，初始化的时候会吧AQS中的state字段设置-1，后面允许中断会将这个值修改。

会通过线程工厂创建一个线程和当前的worker绑定,创建线程的runable接口对象就是work本身。worker重写的run方法实际调用了线程池的runWorker方法