原理
线程池会带着一个队列。
第一个任务开始的时候, 如果当前线程池还有剩余空闲的线程,则直接进入线程池,获取到线程执行任务。 如果没有空闲的线程, 则进入等待队列, 线程池有空闲的线程以后, 再从队列获取任务来执行。
核心配置参数
corePoolSize : 核心线程数,空闲时间后,不会销毁
maximunPoolSize: 额外处理任务的线程数,空闲一段时间(keepAliveTime)后, 线程会销毁。
keepAliveTime:线程释放的时间
常用Fix线程池
使用无界队阻塞列会有什么问题
任务处理慢的时候, 队列会无限变大, 内存就会塞满, 还可能出现OOM
使用优先队列,满了以后出现什么问题
使用有限的队列,会导致任务被拒绝掉。 可以开发一些拒绝的策略, 将拒绝掉的任务保存到硬盘持久化。
宕机的话,队列里面的任务怎么处理
这样重启任务会丢失, 可以做线程任务的持久化, 写入redis或者数据库。 处理完就标记处理完。 没有处理完的,在机器重启后, 从redis和数据库里面读取出来, 重新放到线程池进行处理。
网友评论