正在查找等待从ArrayBlockingQueue轮询的任务数？

Question

问题是，我无法获取在此ArrayBlockingQueue等待获取db连接的线程数。我查看了文档，其中似乎与我想要的内容无关，因为想要获得db连接的任务是线程，我不确定如何手动计算等待db连接的任务数。

感谢任何帮助。

Answer 1

出于测试目的，用自己的类包装ArrayBlockingQueue，并在类中使用AtomicInteger。

当一个新线程等待时，增加原子整数，当一个线程完成时，减少原子整数。

您现在可以随时随地记录或查看该原子整数的值。

Answer 2

如果不使用反射，我唯一能想到的就是拦截对ABQ中任何poll/remove方法的调用。你可以扩展ABQ，让一些计数器在调用超级计数器之前递增，然后最终递减。

private final AtomicInteger count = new AtomicInteger(0);
// if you are using Java 8 I would prefer LongAddr
public T poll(){
   count.incrementAndGet();
   try {
        return super.poll()
   }finally{
      count.decrementAndGet();
   }
}