如何在executor服务中获取队列中的任务数？

Question

所以我使用executorservice创建了一个线程池。

ExecutorService executor = Executors.newSingleThreadExecutor();

我试图访问线程池队列中的任务数。我看到没有办法得到它。我知道有一些方法来获取线程池执行器中的队列大小，但是我如何使用执行器服务对象来实现这一点。

就像我说的，如果我创建了一个像这样的线程池执行器，我可以得到队列信息

ThreadPoolExecutor tpExecutor =  new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>());

我知道我可以使用tpExecutor。队列size（）获取线程池队列中的任务数。但目前我已经使用Executor服务声明了我的线程池。我该怎么做？如果人们能够编写代码并进行演示，这将是非常可观的。

Answer 1

您可以将此强制转换为ThreadPoolExec导师。

ThreadPoolExecutor ex=（ThreadPoolExecutor）executor；例如getQueue（）。大小（）；

Answer 2

我认为这应该奏效：

    ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor) this.executorService;
    int activeCount = threadPoolExecutor.getActiveCount();
    long taskCount = threadPoolExecutor.getTaskCount();
    long completedTaskCount = threadPoolExecutor.getCompletedTaskCount();
    long tasksToDo = taskCount - completedTaskCount - activeCount;

出于某种原因，它并不总是排除所有被取消的任务，只是在一些定期清理之后。所以我不得不引入第二个计数器：

    long tasksToDo2 = threadPoolExecutor.getQueue().stream().filter(t -> !((FutureTask) t).isDone()).count();