ThreadPoolExecutor 运作机制再次理解 ----- 一次小坑记

xiaoxiao2025-10-13  7

private static final ExecutorService executorService = new ThreadPoolExecutor(20, 25, 1000, TimeUnit.MILLISECONDS, new LinkedBlockingQueue(1), new ThreadPoolExecutor.CallerRunsPolicy());

这里核心线程数20

最大线程数25

blockingQueue 最大size 1

reject策略 java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy

 

背景:

一次请求分20次查询,使用多线程并行执行提高效率

出现问题:

总是会出现任务直接进入reject策略

出现原因:

ThreadPoolExecutor中的workers除了第一次是直接接受任务并启动后,再接第二个任务时都是从BlockingQueue获取,然而这里BlockingQueue设置的size是1。因此后续的任务都是直接尝试进BlockingQueue,只要该任务还没有从BlockingQueue消费掉就会超出max size。从而走reject策略。

理解出入

开始理解的是每个workers都会直接拿任务,然而却是通过blockingqueue这种拿。

 

修改:

修改也是很简单了,调大blockingQueue 的 大小。

这里不由自主想到消息队列,这从思想上并没有太多不同吧

 

转载请注明原文地址: https://www.6miu.com/read-5037848.html

最新回复(0)