从执行器服务池（JAVA）中查找等待线程的作业数量？

Question

我有一个服务器，它有多个使用java executorService实现的工作线程（即线程池）

我的问题是，我不能每秒记录一次，如果线程池中没有空闲线程可用，那么等待处理的作业的长度。

注意：日志记录不是我的问题，但我希望能够看到有多少任务/作业等待工作线程处理，是否仍然可以看到executor服务中等待队列（而不是线程池）的长度？

我不知道如何实现这个东西。

Answer 1

就像建议使用ThreadPoolExecatorService而不是ExecutorService一样，您可以利用ThreadPoolExecator类中存在的阻塞队列。这将为您提供等待的线程数。

此外，ThreadPoolExecitor类具有获取已提交任务和已执行任务的计数的方法。

请参考

线程池

封锁队列

希望这有帮助

Answer 2

如果您可以假设您的服务器使用的ExecutorService实现是ThreadPoolExecator，那么您可以使用方法getQueue（）返回尚未分配给Worker的任务数。

/**
 * Returns the task queue used by this executor. Access to the
 * task queue is intended primarily for debugging and monitoring.
 * This queue may be in active use.  Retrieving the task queue
 * does not prevent queued tasks from executing.
 *
 * @return the task queue
 */
public BlockingQueue<Runnable> getQueue() {
    return workQueue;
}

所以你可以这样运行：

 if(LOGGER.isDebugEnabled()) {
    LOGGER.debug(String.format("Pending tasks: %d", executor.getQueue().size()));
 }

Answer 3

ThreadPoolExecutor构造函数接受一个BlockingQueue参数，该参数是用于存储等待的作业的Queue实现。您可以使用getQueue（）方法请求此队列，然后检查队列的大小：

System.out.println("Number of waiting jobs: "+executor.getQueue().size());

请注意，此方法在ExecutorService接口中不可用，因此最好显式构造ThreadPoolExecutor，而不是使用Executors。newFixedThreadPool和朋友：

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

而执行者。OpenJDK/OracleJDK中的newFixedThreadPool也执行相同的操作，没有指定它，因此使用（ThreadPoolExecutor）执行器。newFixedThreadPool（nThreads）可能会在未来的Java版本或替代JDK实现中导致ClassCastException。