java中的ThreadPoolExecutor

1. 为什么要使用线程池

  1. 降低资源消耗。通过重复利用已创建的线程降低线程创建和销毁造成的消耗。
  2. 提高响应速度。当任务到达时，任务可以不需要的等到线程创建就能立即执行。
  3. 提高线程的可管理性。线程是稀缺资源，如果无限制的创建，不仅会消耗系统资源，还会降低系统的稳定性，使用线程池可以进行统一的分配，调优和监控。但是要做到合理的利用线程池，必须对其原理了如指掌。

2. ThreadPoolExecutor中的构造器

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

corePoolSize（基本大小）:指定了线程池中的核心线程数量， 也就是线程池的目标大小。只有在工作队列满了的情况下才会创建超出这个数量的线程。

maximumPoolSize:指定了线程池中的总线程数量，为了保证系统资源有控制的消耗。

keepAliveTime:当线程池中空闲线程数量超过corePoolSize时，多余的线程会在多长时间内被销毁；

unit:keepAliveTime的单位

workQueue:任务队列，被添加到线程池中，但尚未被执行的任务；它一般分为直接提交队列、有界任务队列、无界任务队列、优先任务队列几种；

threadFactory:线程工厂，用于创建线程，一般用于给线程命名；

handler:拒绝策略；当任务太多来不及处理时，如何拒绝任务；

**3. ThreadPoolExecutor中的构造器参数的额外说明 **

1.刚刚创建ThreadPoolExecutor的时候，线程并不会 立即启动，而是要等到有任务提交时才会启动。如果预先调用了prestartCoreThread()/prestartAllCoreThreads()，则会事先启动核心线程。

2. 考虑到keepAliveTime()和allowCoreThreadTimeOut()超市参数的影响，没有任务或者没有足够任务执行的时候，线程池中运行线程的数量（线程池的大小）小于等于corePoolSize。

3. 由于maximumPoolSize可以在运行中通过setMaximumPoolSize()来设置，所以可以通过largestPoolSize()方法来获得线程池曾经运行过的最大线程数量，来评估当前maximumPoolSize设置是否合适。

4. 对于核心线程，默认一直保留存活，如果将allowCoreThreadTimeOut设置为true，则核心线程也接受keepAliveTime的约束。

4. 关于BlockingQueue的详细说明：

此BlockingQueue的实现有：
->ArrayBlockingQueue:基于数组结构的有届阻塞队列，FIFO
->LinkedBlockingQueue:基于链表的阻塞队列，FIFO。吞吐量大于上者。静态工厂方法Executors.newFixedThreadPool()使用了这个队列
->SynchronousQueue:一个不存储元素的阻塞队列。每个插入操作必须等到另一个线程调用移除操作，否则插入操作一直处于阻塞状态，吞吐量高于LinkedBlockingQueue.静态工厂方法Executors.newCachedThreadPool()使用了这个队列。
->PriorityBlockingQueue:一个具有优先级的无限阻塞队列。

5. 关于RejectedExecutionHandler的详细说明：

当队列和线程池都满了之后的饱和策略。默认情况下是AbortPolicy,表示无法处理新任务时抛出异常。以下是JDK1.5提供的四种策略：
->AbortPolicy:直接抛出异常
->CallerRunsPolicy:只用调用者所在的线程来运行任务。
->DiscardOldestPolicy:丢弃队列里最近一个任务，并执行当前任务。
->DiscardPolicy:不处理，丢弃掉。
->也可以根据应用场景需要来实现RejectedExecutionHandler接口自定义策略。如记录日志或持久化不能处理的任务。