对线面试官 - 线程池 (四)

面试官: 你好！今天我们来谈谈线程池的一些概念和工作原理。首先，当任务数超过线程池的核心线程数时，默认情况下会将任务添加到队列中，等待核心线程的处理。当队列已满时，才会启用线程池的最大线程数来处理任务。你在之前的描述中提到了一种方法，可以让任务直接启用最大的线程数，请问你能具体介绍一下这个方法吗？

派大星: 当然可以！要实现任务直接启用最大的线程数，我们可以在创建线程池时指定一个特殊的阻塞队列参数，即 SynchronousQueue。SynchronousQueue 是一种特殊的队列，它不会存储元素，每次生产一个任务时，需要立即指定一个消费者来处理该任务，否则生产者会被阻塞。

面试官: 很好！使用 SynchronousQueue 作为阻塞队列的参数，确实可以实现任务直接启用最大的线程数。那么，接下来我想问一下，线程池如何知道一个线程的任务执行完成呢？

派大星: 当我们将任务丢给线程池执行时，线程池会调度工作线程来执行任务的 run 方法。当任务的 run 方法正常执行结束后，也就意味着任务完成。线程池中的工作线程会通过同步调用任务的 run 方法，并等待其返回结果后，再统计任务的完成数量。

面试官: 很好，你对线程池的任务执行状态了解得很清楚！那么，如果我们想从外部获取线程池内部的任务执行状态，有哪些方法可以实现呢？

派大星: 有几种方法可以实现从外部获取线程池内部的任务执行状态。

• 首先是使用 isTerminated()方法，该方法是线程池提供的一个方法，可以判断线程池的运行状态。我们可以循环调用 isTerminated()方法，一旦返回 Terminated 就表示线程池中的所有任务都已经执行完成了。但需要注意的是，使用该方法前提是程序需要主动调用 shutdown()方法来关闭线程池。

• 另一种方法是使用线程池中的 submit()方法，它返回一个 Future 对象，通过调用 future.get()方法可以获取任务的执行结果。因为 future.get()方法在任务执行完成之前是阻塞的，只有任务执行完毕后才会正常返回，所以可以通过判断该方法的返回来确定传入线程池的任务是否已经执行完成。

• 还有一种方法是使用 CountDownLatch 类，它是 Java 并发工具包中的一个计数器。我们可以初始化一个计数器，然后使用 await()方法阻塞线程，以及 countDown()方法进行倒计时。一旦倒计时为 0，所有被阻塞在 await()方法的线程都会被释放。

• 
  

面试官: 你对线程池的工作原理和任务执行状态的解释非常清楚，总结得很好！通过这些方法，我们可以灵活地获取线程池中任务的执行状态。非常感谢你的解答！

派大星: 不客气！我很高兴能回答你的问题。如果还有其他问题，我随时都可以回答哦！

如有问题，欢迎加微信交流：w714771310，或关注微信公众号【码上遇见你】。