我有一个使用创建的线程池
java.util.concurrent.ThreadPoolExecutor
我可以等到泳池空闲吗?我的意思是所有线程都没有运行,队列中没有任何东西在等待。
我搜索了网络,所有解决方案都不适合我。例如,我不想关闭池,因此
awaitTermination()
不起作用。我也知道如何 getTaskCount()
但我不想继续轮询池,这会浪费 CPU。
这是一个大型项目,我不想更改池中运行的所有任务,因此我正在寻找一些不依赖于任务协作的解决方案。所以闩锁或障碍物对我不起作用。
您可以子类化 ThreadPoolExecutor 并使用 beforeExecute 和 afterExecute 添加挂钩来跟踪任务执行情况,包括计算当前正在执行的任务的基本数学。还可以使用 getQueue() 直接访问队列。
在这些之间,您可以轻松实现您要求的跟踪。 我很好奇你的用例是什么......当池空时你会怎么处理它?
我想知道这是否适用于现实世界的环境。它涉及子类化
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();
}