线程池的核心参数
(1).corePoolSize:设置一个线程池中的核心线程数
如果设置allowCoreThreadTimeOut为false的情况下:
即使当线程池中的线程处于空闲状态,这些线程也不会被线程池中移除。
如果设置了allowCoreThreadTimeOut为true,
那么当核心线程在空闲了一段时间后依旧没有用于工作,那么将会从线程池中移除。
注意:(allowCoreThreadTimeOut默认为false,通常情况下也无需做修改)
(2).maximumPoolSize:线程池中所允许创建最大线程数量
(3).keepAliveTime:当线程池中的线程数量大于核心线程数,
如果这些多出的线程在经过了keepAliveTime时间后,
依然处于空闲状态,那么这些多出的空闲线程将会被结束其生命周期。
(4).unit:keepAliveTime的时间单位
(5).workQueue:用于存放任务的阻塞队列,当线程池中的核心线程都处在执行任务时,
提交的任务将被存储在workQueue进行缓冲。
该队列只能存放通过execute方法提交的Runnable任务。
(6).threadFactory:线程池中用于创建线程的工厂
在这里使用线程工厂的目的也是为了解耦,将创建的实现细节通过工厂进行封装,
而不是直接将创建的方式固化在ThreadPoolExecutor本身的代码中。
(7)handler:当线程池中的线程数量达到最大并且阻塞队列也已经满了无法再添加任务时,
线程池所采取的处理策略。
线程源码解析:http://blog.csdn.net/yuenkin/article/details/51040001
线程池直线线程是去创建一个worker,池中维护一个workqueue。每个worker独立的维护一个线程。独立的去执行加入的线程。如果是核心线程创建的worker ,queue为空时,会阻塞。
execute方法,三步走:
* 1. 如果RUNNING的线程数目小于corePoolSize,直接调用addWorker方法
* 启动一个新线程。addWorker函数会检查runState和workerCount,如果不
* 需要新建一个thread就会返回false了
*
* 2. 如果任务被成功的放入了workQueue,我们仍然需要做个double-check
* 因为调用完isRunning(c)后池中的线程可能都退出了或者线程池被shut
* down了。重新检查状态看是要remove掉新来的任务还是创建一个新线程来执
* 行(如果没有活动的线程了)
*
* 3. 如果放入workQueue失败了,我们尝试创建一个新worker。如果失败了,
* 说明线程池被关闭了或者饱和了(超过最大值了),就直接拒了。
Executors.newFixedThreadPool(1); 先走 第一步,然后后续有任务进来,一直用第一次创建的worker处理。
newCachedThreadPool() ;因为没有核心线程,并且用的是SynchronousQueue阻塞队列,所以直接走第三步。