面试突击：如何判断线程池已经执行完所有任务了？(面试秘籍：如何判断线程池已彻底完成所有任务？)

原创

ithorizon 7个月前 (10-20) 阅读数 15 #后端开发

面试突击：怎样判断线程池已经执行完所有任务了？

一、线程池简介

在现代软件开发中，线程池是一种常用的并发编程技术，它能够有效地管理线程资源，尽也许降低损耗程序性能。线程池通过复用一组线程来执行多个任务，避免了频繁创建和销毁线程的开销。Java中的线程池首要是由`ExecutorService`接口及其实现类（如`ThreadPoolExecutor`）来实现的。

二、线程池任务执行流程

当我们将任务提交给线程池时，线程池的工作流程大致如下：

1. 如果线程池中的线程数量小于核心线程数，则创建新线程执行任务。

2. 如果线程池中的线程数量大于等于核心线程数，但小于最大线程数，将任务放入队列中等待执行。

3. 如果队列已满，且线程数量小于最大线程数，则创建新线程执行任务。

4. 如果线程池中的线程数量已经约为最大线程数，则凭借拒绝策略拒绝任务。

三、怎样判断线程池已经执行完所有任务

要判断线程池是否已经执行完所有任务，我们可以采用以下几种方法：

1. 使用`isTerminated()`方法

`isTerminated()`方法是`ExecutorService`接口中的一个方法，它用于判断线程池中的所有任务是否已经执行完毕。当线程池中的所有任务都已执行完毕，且所有线程都已终止时，该方法将返回`true`，否则返回`false`。


// 示例代码
ExecutorService executor = Executors.newFixedThreadPool(10);
for (int i = 0; i < 100; i++) {
    executor.submit(() -> {
        // 执行任务
    });
}
executor.shutdown();
while (!executor.isTerminated()) {
    // 等待线程池中的任务执行完毕
}
System.out.println("所有任务执行完毕");

2. 使用`awaitTermination()`方法

`awaitTermination()`方法是`ExecutorService`接口中的另一个方法，它允许我们等待线程池中的所有任务在给定时间内完成。如果在等待时间内所有任务都已完成，则返回`true`，否则返回`false`。


// 示例代码
ExecutorService executor = Executors.newFixedThreadPool(10);
for (int i = 0; i < 100; i++) {
    executor.submit(() -> {
        // 执行任务
    });
}
executor.shutdown();
try {
    if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
        System.out.println("等待超时，仍有任务未完成");
    }
} catch (InterruptedException e) {
    e.printStackTrace();
}
System.out.println("所有任务执行完毕");

3. 使用`shutdownNow()`方法

`shutdownNow()`方法会尝试停止所有正在执行的任务，并返回尚未起初执行的任务列表。当调用`shutdownNow()`方法后，我们可以检查返回的任务列表是否为空，来判断线程池是否已经执行完所有任务。


// 示例代码
ExecutorService executor = Executors.newFixedThreadPool(10);
List tasks = new ArrayList<>();
for (int i = 0; i < 100; i++) {
    tasks.add(() -> {
        // 执行任务
    });
}
executor.shutdownNow();
if (tasks.isEmpty()) {
    System.out.println("所有任务执行完毕");
} else {
    System.out.println("仍有任务未完成");
}