线程池
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。