我有ThreadPoolExecutor和下一个params:
corePoolSize = 20
maximumPoolSize = 100
workQueue = new LinkedBlockingQueue(10)每秒钟我提交1k任务。任务代表一些IO操作,需要1-2s。其中一些被拒绝了。这是意料之中的。我使用自定义AbortPolicy在拒绝之前记录线程池状态。
在日志中我看到了一些我无法解释的东西。信息如下:
java.util.concurrent.ThreadPoolExecutor@3e6be2d8Running,池大小= 100,活动线程= 2,排队任务= 10,完成任务= 4471827。
我在文档中发现了getActiveCount方法Returns the approximate number of threads that are actively executing tasks.,但是它不能帮助我理解.
“活动线程”在这里意味着什么?为什么池已达到极限时只有2个线程处于活动状态,队列已满,任务被拒绝?
我想增加maximumPoolSize以同时处理更多的任务,但是首先我需要了解是否有效地使用ThreadPool资源。
发布于 2020-08-05 00:39:05
“活动线程”是指从工作队列中开始执行任务的线程。
当线程启动或成为空闲时,它们不会“立即”捡起一个任务--存在从队列中读取的争用。如果您在一个紧密的循环中将100个任务提交给执行者,很可能到最后只有几个工作线程有机会获得一个任务。
要更好地了解实际运行任务的线程数量,请按常规计划记录活动线程数,例如每秒10次。
https://stackoverflow.com/questions/63256056
复制相似问题