1.线程池是什么?
线程池简单的说就是管理线程的一个总调度官。它可以存储着多个核心线程和多个非核心线程,也可以派遣核心线程或非核心线程去处理事情。线程池原理简单的解释就是会创建多个线程并且进行管理,提交给线程的任务会被线程池指派给其中的线程进行执行,通过线程池的同意调度,管理使得多线程的使用更简单,高效。
2.为什么要使用线程池?
1.重用线程池中的线程,避免因为线程的创建和销毁所带来的性能开销。
2.能有效控制线程池的最大并发数,避免大量的线程之间因互相抢占系统资源而导致的阻塞现象。
3.能够对线程简单的管理,并提供定时执行以及指定间隔循环执行等功能。
3.怎么样使用线程池?
一、真正的线程池只有一个类:ThreadPoolExecutor,而四大线程池则是不同功能的线程池
二、线程池采用的是工厂模式,其四大线程池就是由老大打造出来的
1.ExecutorService fixedThreadExecutor = Executors.newFixedThreadPool(5);
2.ExecutorService cachedThreadExecutor = Executors.newCachedThreadPool();
3.ExecutorService scheduledThreadExecutor = Executors.newScheduledThreadPool(5);
4.ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
三、四大线程池之老大ThreadPoolExecutor
ThreadPoolExecutor是线程池的真正实现,它的构造方法提供了一系列参数来配置线程池,其构造方法如下
public ThreadPoolExecutor(intcorePoolSize,intmaximumPoolSize,longkeepAliveTime, TimeUnit unit, BlockingQueue workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)
参数的实际意义
1、corePoolSize
线程池的核心线程数,默认情况下,核心线程会在线程池中一直存活,即使它们处于闲置状态。如果将ThreadPoolExecutor的allowCoreThreadTimeOut属性设置为true,那么闲置的核心线程在等待新任务到来时会有超时策略,这个时间间隔由keepAliveTime所指定,当等待时间超过keepAliveTime所指定的时长后,核心线程就会被终止
2、maximumPoolSize
线程池所能容纳的最大线程数,当活动线程数达到这个数值后,后续的新任务将会被阻塞
3、keepAliveTime
非核心线程闲置时的超时时长,超过这个时长,非核心线程就会被回收。当ThreadPoolExecutor的allowCoreThreadTimeOut属性设置为true时,keepAliveTime同样会作用于核心线程
4、unit
于指定keepAliveTime参数的时间单位,常用的有TimeUnit.MILLISECONDS(毫秒),秒,分钟等
5、workQueue
线程池中的任务队列,通过线程池的execute方法提交的Runnable对象会存储在这个参数中
6、threadFactory
线程工厂,为线程池提供创建新线程的功能
7、handler
当线程池无法执行新任务时,这可能是由于任务队列已满或者是无法成功执行任务,这个时候ThreadPoolExecutor会调用handler的rejectedExecution方法来通知调用者
四大线程池之FixedThreadPool
一、FixedThreadPool的分析
FixedThreadPool是一种线程数量固定的线程池,当线程处于空闲状态时,它们并不会被回收,除非线程池被关闭了。下面是创建FixedThreadPool的源码
public static ExecutorService newFixedThreadPool( intnThreads) {
returnnewThreadPoolExecutor(nThreads, nThreads,0L,
TimeUnit.MILLISECONDS,newLinkedBlockingQueue());}
其特点是:
1.线程数量固定
2.空闲不会被回收
3.更快的响应速度
4.无超时机制,无大小限制
四大线程池之CachedThreadPool
一、CachedThreadPool的分析
CachedThreadPool是一种线程数量不定的线程池,它只有非核心线程,并且其最大线程数为Integer.MAX_VALUE,下面是创建CachedThreadPool的源码
public static ExecutorService newCachedThreadPool() {returnnewThreadPoolExecutor(0, Integer.MAX_VALUE,60L, TimeUnit.SECONDS,newSynchronousQueue());}
其特点是:
1.只有最大线程数为int的最大值
2.超时时间为60秒
3.当整个线程池都出去闲置状态超过60秒的时候,会被回收
4.几乎不占用任何系统资源
四大线程池之ScheduledThreadPool
一、ScheduledThreadPool的分析
ScheduledThreadPool是一种核心线程数量时固定的,而非核心线程数是没有限制的,并且当非核心线程闲置时会被立即回收。下面是创建ScheduledThreadPool的源码
public static ScheduledExecutorService newScheduledThreadPool(intcorePoolSize) {returnnewScheduledThreadPoolExecutor(corePoolSize);}publicScheduledThreadPoolExecutor(intcorePoolSize) {super(corePoolSize, Integer.MAX_VALUE, DEFAULT_KEEPALIVE_MILLIS, MILLISECONDS,newDelayedWorkQueue());}
其特点是:
1.核心数量固定
2.非核心数量无限制
3.非核心线程闲置时立即被回收
四大线程池之SingleThreadExecutor
一、SingleThreadExecutor的分析
SingleThreadExecutor是一种只有一个核心线程的线程池,它确保所有的任务都在同一个线程中按顺序执行。下面是创建SingleThreadExecutor的源码
public static ExecutorService newSingleThreadExecutor() {returnnewFinalizableDelegatedExecutorService (newThreadPoolExecutor(1,1,0L, TimeUnit.MILLISECONDS,newLinkedBlockingQueue()));}
其特点是:
1.只有一个核心线程
简单记忆(以线程数量为线索)
1.FixedThreadPool:核心固定,非核心为固定
2.CachedThreadPool:核心为0,非核心无限制
3.ScheduledThreadPool:核心固定,非核心无限制
4.SingleThreadExecutor:核心为1,非核心为1