本人今年参加了很多面试,也有幸拿到了一些大厂的offer,整理了众多面试资料,后续还会分享众多面试资料,感兴趣的朋友可收藏+关注,
现分享如下:
文章目录
- 1. 线程池重要参数
- 2. 线程池状态
- 3. 优雅停止线程
- 4. 线程池的好处?线程池类型?
1. 线程池重要参数
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler)
(1)corePoolSize: 核心线程数,线程池维护的最小线程数量
线程池维护的最小线程数量,核心线程创建后不会被回收(注意!!设置
allowCoreThreadTimeOut=True后,空闲的核心线程数超过存活时间也会被回收)。
大于核心线程数的线程,在空闲时间超过keepAliveTime后会被回收。
线程池刚创建时,里面没有一个线程,当调用 execute() 方法添加一个任务时,如果正在运行的线程数量小于corePoolSize,则马上创建新线程并运行这个任务。
(2)maximunPoolSize: 最大线程数
线程池允许创建的最大线程数量。
当添加一个 任务时,核心线程已满,线程池还没有达到最大线程数,并且没有空闲线程,工作队列已满的情况下,就会创建一个新线程并执行。
(3)keepAliveTime: 空闲线程存活时间
当一个可被回收的线程的空闲时间大于keepAliveTime时,该线程就会被回收。
可被回收的线程包含:
1)设置为allowCoreThreadTimeout=True的核心线程
2)大于核心线程数的线程(即:非核心线程)
(4)unit: keepAliveTime的时间单位
1.TimeUnit.NANOSECONDS
2.TimeUnit.MICROSECONDS
3.TimeUnit.MILLISECONDS // 毫秒
4.TimeUnit.SECONDS
5.TimeUnit.MINUTES
6.TimeUnit.HOURS
7.TimeUnit.DAYS
(5)workQueue: 存放待执行任务的工作队列
当提交的任务数超过核心线程数大小后,再提交的任务就存放在工作队列,任务调度时再从队列中取出任务。它仅仅用来存放被execute()方法提交的Runnable任务。工作队列实现了BlockingQueue接口。
· ArrayBlockingQueue: 基于数组的有界阻塞队列,按FIFO排序。新任务进来后,会放到该队列的队尾,有界的数组可以防止资源耗尽问题。当线程池中线程数量达到corePoolSize后,再有新任务进来,则会将任务放入该队列的队尾,等待被调度。如果队列已经是满的,则创建一个新线程,如果线程数量已经达到maxPoolSize,则会执行拒绝策略。
· LinkedBlockingQueue: 基于链表的无界阻塞队列,按FIFO排序。由于该队列的近似无界性,当线程池中线程数量达到corePoolSize后,再有新任务进来,会一直存入该队列,而不会去创建新线程直到maxPoolSize,因此使用该工作队列时,参数maxPoolSize其实是不起作用的。
· SynchronousQueue: 一个不缓存任务的阻塞队列,生产者放入一个任务必须等到消费者取出这个任务。也就是说,新任务进来时,不会缓存该任务,而是直接被调度执行该任务,如果没有可用线程,则创建新线程;如果线程数量达到maxPoolSize,则执行拒绝策略。
· PriorityBlockingQueue: 具有优先级的无界阻塞队列,优先级通过参数Comparator实现。
(6)ThreadFactory: 线程工厂
创建线程的工厂,可以设定线程名,线程编号
(7)handler: 拒绝策略
当线程池线程数已满,并且工作队列达到限制,新提交的任务使用拒绝策略处理。可以
自定义拒绝策略,拒绝策略需要实现RejectedExecutionHandler接口。
JDK默认的拒绝策略有四种:
· AbortPolicy: 丢弃任务并抛出RejectedExecutionException异常。
· DiscardPolicy: 丢弃任务,但是不抛出异常。可能导致无法发现系统的异常状态。
· DiscardOldestPolicy: 丢弃队列最前面的任务,然后重新提交被拒绝的任务。
· CallerRunsPolicy: 由调用线程处理该任务。
线程执行流程:
2. 线程池状态
3. 优雅停止线程
开启线程可以使用start()方法,停止线程的方法有:
(1)stop(): 不建议使用
但不建议stop方法,因为stop()相对粗暴,一旦调用stop(),就会直接停掉线程,这样就存在严重问题,比如:任务执行到哪一步?该释放的锁释放了吗?
需要强调的是:stop()会释放线程占用的synchronized锁,而不会自动释放ReentrantLock锁。
(2)通过中断的方式interrupt:推荐使用
可以使用interrupt()的方式,来优雅的控制线程暂停。如下代码:
可以通过interrupt()的方式来控制子线程是否终止,子线程也可以根据信号来终止线程了。
4. 线程池的好处?线程池类型?
线程池的好处:
(1)降低资源消耗:通过重复利用已创建的线程,降低线程创建和销毁造成的资源消耗;
(2)提高响应速度:当任务到达时,任务可以不需要线程创建即可立即执行;
(3)提高线程的可管理性:线程是稀缺资源,如果无限制的创建,不仅会消耗系统资源,还会降低系统的稳定性,使用线程池可以同一分配、调优和监控。
四种线程类型:
(1)newCachedThreadPool:适用短期异步任务
创建一个可缓存线程池,当线程池的数量过大,它可以有效回收多余的线程,如果线程数量不足,那么它可以创建新的线程。
优点:复用率较高,如果第二个任务开始时,第一个任务已经结束,则第二个任务会服用第一个任务的线程,而不会重开线程;
不足:虽然可以根据业务自动扩展线程数来拓展业务,但是最多需要多少个线程同时处理确是我们无法控制的。
(2)newFixedThreadPool:适用长期异步任务
创建一个定长的线程池,可控制线程最大并发数,超出的线程会在队列中等待;
(3)newScheduleThread:适用周期性任务
创建一个可定期或延时执行的定长线程池,支持定时和周期性执行任务;
创建一个固定大小的线程池,线程池内线程存活时间无限制,线程池可以支持定时及周
期性任务执行,如果所有线程均处于繁忙状态,对于新任务会进入DelayedWorkQueue队列中,这是一种按照超时时间排序的队列结构
(4)newSingleThreadExcutor:适用按顺序执行任务
创建一个单线程的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指
定顺序(FIFO, LIFO,优先级)进行执行。
多线程篇完结,撒花!