使用ThreadPoolExecutor的活动任务数

Question

我正在使用ThreadPoolExecutor在我的Java应用程序中执行任务.我有一个要求,我想在执行程序队列中的任何时间点获取队列中的活动任务数.我查看了ThreadPoolExecutor 的javadoc,发现了两个相关的方法:getTaskCount()和getCompletedTaskCount().

根据文档,我可以分别从上述两种方法中获得计划任务和已完成任务的数量.但我无法找到在任何时间点获取队列中活动任务数量的解决方案.我可以这样做:

getTaskCount() = getCompletedTaskCount() + failed tasks + active tasks

但是,无法直接获得失败任务的数量以达到预期的计算.

我在这里错过了什么吗？

Answer 1

我不认为您需要通过您尝试使用的计算来了解失败的计数.

long submitted = executor.getTaskCount();
long completed = executor.getCompletedTaskCount();
long notCompleted = submitted - completed; // approximate

会(大约)足够.

或者,你可以用getQueue()与size():

int queued = executor.getQueue().size();
int active = executor.getActiveCount();
int notCompleted = queued + active; // approximate

这个答案假设你正在寻找一个"尚未完成"的计数.你的问题与自己相矛盾,所以我不完全确定你在问什么.如果这不正确,请回复我对您的问题的评论,我会相应地更新此答案.