有没有办法确定newFixedThreadPool队列中有多少个runnables？

Question

我在主程序发射了

Executors.newFixedThreadPool(100); 

和制片人在工作快于消费者能跟上抽。有没有办法查看newFixedThreadPool使用的基础无界队列中排队的项目数量？

Answer 1

使用java.util.concurrent.ThreadPoolExecutor#getTaskCount得到的线程池中计划任务数。但是，请注意，这只是一个近似值，可能并不准确。

如果要解决生产者生产任务比消费者更快的问题，请限制底层队列的大小，并在创建java.util.concurrent.ThreadPoolExecutor时通过RejectedExecutionHandler的实现之一。见从ThreadPoolExecutor的文档下面的代码片段：

拒绝任务的当执行程序已关闭

的方法execute(java.lang.Runnable)提交的新任务将被拒绝，并且也当Executor使用的有限范围最大线程数和工作队列容量都是饱和的。在任一情况下，执行方法调用其RejectedExecutionHandler的RejectedExecutionHandler.rejectedExecution(java.lang.Runnable, java.util.concurrent.ThreadPoolExecutor)方法。提供四个预定义的处理程序策略：

1. 在默认ThreadPoolExecutor.AbortPolicy，处理程序拒绝时抛出一个运行时RejectedExecutionException。
2. 在ThreadPoolExecutor.CallerRunsPolicy，调用执行自身的线程运行的任务。这提供了一个简单的反馈控制机制，可以减慢提交新任务的速度。
3. 在ThreadPoolExecutor.DiscardPolicy，不能执行仅仅是被丢弃的任务。
4. 在ThreadPoolExecutor.DiscardOldestPolicy，如果执行程序没有关闭，在工作队列头部的任务将被丢弃，然后执行重试（可再次失败，导致此重复。）

可以定义和使用其他种类的类。这样做需要特别注意，特别是在政策旨在仅在特定容量或排队策略下工作时。