线程状态
1. 新建
2. 可运行
3. 运行
4. 阻塞
5. 消亡
线程状态转换
线程池的执行逻辑
核心概念:
corePoolSize
maxPoolSize
keepAliveTime:如果当前线程池中线程数大于corePoolSize,
多余的线程,在等待keepAliveTime时间后如果还没有新的线程任务指派给它,它就会被回收
TimeUnit
workQueue
ArrayBlockingQueue:基于数组结构的有界阻塞队列,按FIFO排序任务;
LinkedBlockingQuene:基于链表结构的阻塞队列,按FIFO排序任务,吞吐量通常要高于
SynchronousQuene:一个不存储元素的阻塞队列,每个插入操作必须等到另一个线程调用移除操作,否则插入操作一直处于阻塞状态,吞吐量通常要高于ArrayBlockingQuene;
PriorityBlockingQuene:具有优先级的无界阻塞队列;
threadFactory
RejectExecutionHandler: 拒绝策略
ThreadPoolExecutor.AbortPolicy:丢弃任务并抛出RejectedExecutionException异常。
ThreadPoolExecutor.DiscardPolicy:也是丢弃任务,但是不抛出异常。
ThreadPoolExecutor.DiscardOldestPolicy:丢弃队列最前面的任务,然后重新尝试执行任务(重复此过程)
ThreadPoolExecutor.CallerRunsPolicy:由调用线程处理该任务
当然也可以根据应用场景实现RejectedExecutionHandler接口,
自定义饱和策略,如记录日志或持久化存储不能处理的任务。
执行逻辑
1. 当提交一个任务时,线程池创建一个新线程执行任务,直到当前线程数等于corePoolSize
2. 如果当前线程数为corePoolSize,继续提交的任务被保存到阻塞队列中,等待被执行
3. 如果阻塞队列满了,那就创建新的线程执行当前任务;直到线程池中的线程数达到maxPoolSize
4. 这时再有任务来,只能执行reject()处理该任务
image.png
网友评论