Java线程池主要是用于合理创建线程,减少线程创建销毁频率,最大限度利用CPU性能,JVM根据用户配置先创建一定数量的线程,当用户使用时,直接调用启动。
线程池的主要作用是线程复用、线程资源管理、控制操作系统的最大并发数,以保证系统高效(通过线程资源复用实现)且安全(通过控制最大线程并发数实现)地运行。
线程池核心组件
- 线程管理器:用于创建和管理线程
- 工作线程:当前使用的线程
- 任务接口:定义线程和执行策略
- 任务队列:存放待处理的任务
线程池参数
序号 | 参数名 | 参数说明 |
---|---|---|
1 | corePoolSize | 核心线程数 |
2 | maximumPoolSize | 最大线程数 |
3 | keepAliveTime | 非核心线程空闲状态下线程回收时间 |
线程池工作流程
Java线程池的工作流程为:线程池刚被创建时,只是向系统申请一个用于执行线程队列和管理线程池的线程资源。在调用execute()添加一个任务时,线程池会按照以下流程执行任务。
- 如果正在运行的线程数量少于corePoolSize(用户定义的核心线程数),线程池就会立刻创建线程并执行该线程任务。
- 如果正在运行的线程数量大于等于corePoolSize,该任务就将被放入阻塞队列中。
- 在阻塞队列已满且正在运行的线程数量少于maximumPoolSize时,线程池会创建非核心线程立刻执行该线程任务。
- 在阻塞队列已满且正在运行的线程数量大于等于maximumPoolSize时,线程池将拒绝执行该线程任务并抛出RejectExecutionException异常。
- 在线程任务执行完毕后,该任务将被从线程池队列中移除,线程池将从队列中取下一个线程任务继续执行。
-
在线程处于空闲状态的时间超过keepAliveTime时间时,正在运行的线程数量超过corePoolSize,该线程将会被认定为空闲线程并停止。因此在线程池中所有线程任务都执行完毕后,线程池会收缩到corePoolSize大小。
5种常见线程池
ExecutorService创建线程池
序号 | 名称 | 说明 |
---|---|---|
1 | newCachedThreadPool | 可缓存线程,时间短,使用频繁的线程 |
2 | newFixedThreadPool | 规定数量的线程池 |
3 | newScheduledThreadPool | 可调度线程池,延时执行线程 |
4 | newSingleThreadExecutor | 单个线程池,永远保持存在一个,异常或者销毁后,立即会重新创建一个 |
5 | newWorkStealingPool | Java8特有,足够多的线程,提升计算效率,当然也可设置线程数量 |