Java 中如何判断线程池是否空闲

Question

我有一个使用创建的线程池，

java.util.concurrent.ThreadPoolExecutor

我可以等到池空闲吗？我的意思是所有线程都没有运行，队列中没有任何东西在等待。

我搜索了网络，所有解决方案都不适合我。例如，我不想关闭池，因此 awaitTermination() 不起作用。我也知道如何 getTaskCount() 但我不想继续轮询池，这会浪费 CPU。

这是一个大型项目，我不想更改池中运行的所有任务，因此我正在寻找一些不依赖于任务协作的解决方案。所以闩锁或障碍物对我不起作用。

Answer 1

您可以子类化 ThreadPoolExecutor 并使用 beforeExecute 和 afterExecute 添加挂钩来跟踪任务执行情况，包括计算当前正在执行的任务的基本数学。还可以使用 getQueue() 直接访问队列。

在这些之间，您可以轻松实现您要求的跟踪。
我很好奇你的用例是什么......当池空时你会怎么处理它？

Answer 2

我想知道这是否适用于现实世界的环境。它涉及对 ThreadPoolExecutor 进行子类化并向其传递一个 IdleListener：

  @Override
  protected void beforeExecute(Thread t, Runnable r)
  {
    super.beforeExecute(t, r);
    listener.working();
  }

  @Override
  protected void afterExecute(Runnable r, Throwable t)
  {
    super.afterExecute(r, t);
    long activeCount = getTaskCount() - getCompletedTaskCount();
    if (activeCount == 1) // yes, one
    {
      listener.idle();
    }
  }

接口：

  interface IdleListener
  {
    void working();
    void idle();
  }