通过 ThreadPoolExecutor 的方式创建线程池
ThreadPoolExecutor 构造方法:
- public ThreadPoolExecutor(int corePoolSize,
- int maximumPoolSize,
- long keepAliveTime,
- TimeUnit unit,
- BlockingQueue<Runnable> workQueue,
- ThreadFactory threadFactory,
- RejectedExecutionHandler handler) {
- //code...
- }
参数的意义:
1.corePoolSize 指定了线程池里的线程数量, 核心线程池大小
2.maximumPoolSize 指定了线程池里的最大线程数量
3.keepAliveTime 当线程池线程数量大于 corePoolSize 时候, 多出来的空闲线程, 多长时间会被销毁.
4.unit 时间单位
5.workQueue 任务队列, 用于存放提交但是尚未被执行的任务.
6.threadFactory 线程工厂, 用于创建线程, 一般可以用默认的
7.handler 拒绝策略, 当任务过多时候, 如何拒绝任务. 当提交任务数超过 maximumPoolSize + workQueue 的 size 之和, 任务交给 RejectedExecutionHandler 处理
线程池的增长
线程池的增长与创建自定义线程池时设置的参数密切相关, 重点讲解比较容易让人误解的 corePoolsize, maximumPoolsize, workQueue 之 间关系.
先看一张图, 理解一下增长过程
当线程池小于 corePoolsize 时, 新提交的任务将创建一个新的线程执行任务, 即使此时线程池中存在空闲线程.
当线程池达到 corePoolSize 时, 新提交的任务将被放入 workQueue 中, 等待线程池中任务调度执行
当 workQueue 已满, 且线程池 < maximumPoolSize 时, 新提交任务会创建新线程执行任务
当提交任务数超过 maximumPoolSize 时, 新提交任务由 RejectedExecutionHandlier 处理
另外需要特别注意的是, 当线程池中超过 corePoolSize 线程, 空闲时间达到 keepAliveTime 时, 将会关闭空闲线程.
当设置 allowCoreThreadTimeOut(true) 时, 线程池中 corePoolSize 线程空闲时间达到 keepAliveTime 也将关闭
当一个任务通过 execute( Runnable) 方法欲添加到线程池时:
如果此时线程池中的数量小于 corePoolSize, 即使线程池中的线程都处于空闲状态, 也要创建新的线程来处理被添加的任务.
如果此时线程池中的数量等于 corePoolSize, 但是缓冲队列 workQueue 未满, 那么任务被放入缓冲队列.
如果此时线程池中的数量大于 corePoolSize, 缓冲队列 workQueue 满, 并且线程池中的数量小于 maximumPoolSize, 建新的线程来处理被添加的任务.
如果此时线程池中的数量大于 corePoolSize, 缓冲队列 workQueue 满, 并且线程池中的数量等于 maximumPoolSize, 那么通过 handler 所指定的策略来处理此任务. 也就是: 处理任务的优先级为: 核心线程 corePoolSize, 任务队列 workQueue, 最大线程 maximumPoolSize,
如果三者都满了, 使用 RejectedExecutionHandlier 处理被拒绝的任务.(具体怎么处理, 属于拒绝策略的范畴)
当线程池中的线程数量大于 corePoolSize 时, 如果某线程空闲时间超过 keepAliveTime, 线程将被终止. 这样, 线程池可以动态的调整池中的线程数.
来源: https://www.cnblogs.com/ibigboy/p/11298010.html