线程池

线程池

a. 基本组成部分：

1、线程池管理器（ThreadPool）：用于创建并管理线程池，包括创建线程池，销毁线程池，添加新任务；

2、工作线程（PoolWorker）：线程池中线程，在没有任务时处于等待状态，可以循环的执行任务；

3、任务接口（Task）：每个任务必须实现的接口，以供工作线程调度任务的执行，它主要规定了任务的入口，任务执行完后的收尾工作，任务的执行状态等；

4、任务队列（taskQueue）：用于存放没有处理的任务。提供一种缓冲机制。

b. java自带线程池：java.util.concurrent

接口：

java.util.concurrent.Executor

java.util.concurrent.ExecutorService

工厂类，生产(创建)线程池：java.util.concurrent.Executors

四种方式创建线程池：

1、Executors.newFixedThreadPool: 创建一个指定工作线程数量的线程池。每当提交一个任务就创建一个工作线程，如果工作线程数量达到线程池初始的最大数，则将提交的任务存入到池队列中。 【常用】

public static ExecutorService newFixedThreadPool(int nThreads) {

return new ThreadPoolExecutor(nThreads, nThreads,

0L, TimeUnit.MILLISECONDS,

new LinkedBlockingQueue());

}

2、Executors.newCachedThreadPool: 创建一个可缓存的线程池。特点：

1).工作线程的创建数量几乎没有限制(其实也有限制的,数目为Interger. MAX_VALUE), 这样可灵活的往线程池中添加线程。

2).如果长时间没有往线程池中提交任务，即如果工作线程空闲了指定的时间(默认为1分钟)，则该工作线程将自动终止。终止后，如果你又提交了新的任务，则线程池重新创建一个工作线程。

3、Executors.newSingleThreadExecutor: 创建一个单线程化的Executor，即只创建唯一的工作者线程来执行任务，如果这个线程异常结束，会有另一个取代它，保证顺序执行。单工作线程最大的特点是保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行，并且在任意给定的时间不会有多个线程是活动的。

4、Executors.newScheduleThreadPool: 创建一个定长的线程池，而且支持定时的以及周期性的任务执行，类似于Timer。

使用：eg: Executors.newFixedThreadPool(count).submit(runnable)/execute(runnable);

5种丢弃机制处理：实现接口RejectedExecutionHandler方法：public void rejectedExecution(Runnabler, ThreadPoolExecutor e)

1、自定义实现

2、CallerRunsPolicy：如果发现线程池还在运行，就直接运行这个线程

3、DiscardOldestPolicy：在线程池的等待队列中，将头取出一个抛弃，然后将当前线程放进去。

4、DiscardPolicy：什么也不做

5、AbortPolicy：java默认，抛出一个异常： RejectedExecutionException。