dk1.5版本新增了 JUC 并发包,其中一个包含线程池。
四种拒绝策略:
拒绝策略类型说明1ThreadPoolExecutor.AbortPolicy默认拒绝策略,拒绝任务并抛出任务2ThreadPoolExecutor.CallerRunsPolicy使用调用线程直接运行任务3ThreadPoolExecutor.DiscardPolicy直接拒绝任务,不抛出错误4ThreadPoolExecutor.DiscardOldestPolicy触发拒绝策略,只要还有任务新增,一直会丢弃阻塞队列的最老的任务,并将新的任务加入 预先配置 配置线程池。 核心线程和最大线程都尽量设置的小一点,分别设置成 1 和 2阻塞队列设置固定长度的有界队列,长度为 1线程工厂设置默认线程工厂 创建线程任务创建线程任务,一个线程任务执行一秒:
拒绝策略一:AbortPolicy默认拒绝策略,拒绝任务并抛出任务
输出
【任务】4报错:Task com.test.controller.ThreadPoolController$TaskThread@5c0369c4 rejected from java.util.concurrent.ThreadPoolExecutor@50675690[Running, pool size = 2, active threads = 2, queued tasks = 1, completed tasks = 0]【任务】5报错:Task com.test.controller.ThreadPoolController$TaskThread@31b7dea0 rejected from java.util.concurrent.ThreadPoolExecutor@50675690[Running, pool size = 2, active threads = 2, queued tasks = 1, completed tasks = 0]执行任务:1执行任务:3执行任务:2
最大线程数 + 阻塞队列 = 3,执行到4,5的时候就抛出错误。这里需要用 try catch 捕获异常。任务1、2、3正常执行。
如果提交的任务都要执行,可以将抛出的错误任务存入在redis中,然后定时从redis中获取任务,再提交执行。
拒绝策略二:CallerRunsPolicy调用线程运行多余的任务。
更换拒绝策略,将上面的 AbortPolicy 换成 CallerRunsPolicy。
执行任务,输出:
执行任务:1执行任务:4执行任务:3执行任务:2执行任务:5
最大线程数 + 阻塞队列 = 3,多余的任务还是继续被执行。
拒绝策略三:DiscardPolicy拒绝任务,不会抛出错误。更换策略,将CallerRunsPolicy 换成DiscardPolicy:
执行任务,输出:
执行任务:1执行任务:3执行任务:2
MAKEFILE 复制 全屏
多余的线程任务提交被拒绝,而只执行最大线程数 + 阻塞队列 数量的任务,并且不会抛出错误。
拒绝策略四:DiscardOldestPolicy只要还有任务新增,一直会丢弃阻塞队列的最老的任务,并将新的任务加入到阻塞队列中。更换策略,将DiscardPolicy 换成DiscardOldestPolicy:
执行任务,输出:
执行任务:3执行任务:1执行任务:5
任务的执行顺序是 核心线程数 —> 阻塞队列 —> 最大线程数,其中任务1,任务3提交成功。
任务2因为在阻塞队列中,后面的任务4把任务2挤掉,任务5又把任务4挤掉,所以最后执行的是任务5。 总结本文介绍了线程四种拒绝策略,当工作任务大于最大线程 + 阻塞队列会执行阻塞队列。
AbortPolicy 默认策略,拒绝任务,并抛出异常CallerRunsPolicy 调用线程执行对于的任务DiscardPolicy 拒绝任务,不会抛出异常DiscardOldestPolicy 有多余的任务,把阻塞队列最老的任务丢弃,放入新的任务,直到没有新的任务。到此这篇关于Java线程池的四种拒绝策略的文章就介绍到这了,更多相关Java 线程池拒绝策略内容请搜索七叶笔记以前的文章或继续浏览下面的相关文章希望大家以后多多支持七叶笔记!