ThreadPoolExecutor

1. public ThreadPoolExecutor(int corePoolSize,  
2.                               int maximumPoolSize,  
3.                               long keepAliveTime,  
4.                               TimeUnit unit,  
5.                               BlockingQueue<Runnable> workQueue,  
6.                               ThreadFactory threadFactory,  
7.                               RejectedExecutionHandler handler)

 

ThreadPoolExecutor线程池

其中比较容易让人误解的是：corePoolSize，maximumPoolSize，workQueue之间关系。 

 

1.当线程池小于corePoolSize时，新提交任务将创建一个新线程执行任务，即使此时线程池中存在空闲线程。 

 

2.当线程池达到corePoolSize时，新提交任务将被放入workQueue中，等待线程池中任务调度执行 

 

3.当workQueue已满，且maximumPoolSize>corePoolSize时，新提交任务会创建新线程执行任务 

 

4.当提交任务数超过maximumPoolSize时，新提交任务由RejectedExecutionHandler处理 

 

5.当线程池中超过corePoolSize线程，空闲时间达到keepAliveTime时，关闭空闲线程 

 

 

6.当设置allowCoreThreadTimeOut(true)时，线程池中corePoolSize线程空闲时间达到keepAliveTime也将关闭 

 

任务队列：

 

1. ArrayBlockingQueue：基于数组的FIFO队列，是有界的，创建时必须指定大小
2. LinkedBlockingQueue： 基于链表的FIFO队列，是无界的，默认大小是 Integer.MAX_VALUE
3. synchronousQueue:一个比较特殊的队列，虽然它是无界的，但它不会保存任务，每一个新增任务的线程必须等待另一个线程取出任务，也可以把它看成容量为0的队列