ThreadPoolExecutor关闭正在执行的线程

要关闭ThreadPoolExecutor中正在执行的线程，你可以采取以下步骤：

1. 调用ThreadPoolExecutor的`shutdown()`方法来停止接受新的任务。
2. 调用ThreadPoolExecutor的`awaitTermination()`方法等待一段时间，使所有已提交的任务完成执行，或者超过指定的等待时间。
3. 如果在等待时间内仍有任务未完成，你可以调用`shutdownNow()`方法尝试立即停止所有正在执行的线程。

下面是一个示例代码：

// 创建ThreadPoolExecutor
ThreadPoolExecutor executor = new ThreadPoolExecutor(
    corePoolSize,
    maxPoolSize,
    keepAliveTime,
    TimeUnit.MILLISECONDS,
    new LinkedBlockingQueue<>()
);

// 关闭ThreadPoolExecutor
executor.shutdown();

try {
    // 等待所有任务完成执行，或者超时时间达到
    if (!executor.awaitTermination(timeout, TimeUnit.MILLISECONDS)) {
        // 如果超时仍有任务未完成，则尝试立即停止所有正在执行的线程
        executor.shutdownNow();
        // 再次等待一段时间以确保所有线程都被终止
        if (!executor.awaitTermination(timeout, TimeUnit.MILLISECONDS)) {
            // 如果仍有线程未被终止，可以根据实际情况进行处理
            System.err.println("ThreadPoolExecutor未能完全关闭");
        }
    }
} catch (InterruptedException e) {
    // 处理InterruptedException异常
    executor.shutdownNow();
    Thread.currentThread().interrupt();
}

这个例子中，首先调用`shutdown()`方法停止接受新的任务。然后使用`awaitTermination()`方法等待一段时间，如果超过指定的等待时间，则调用`shutdownNow()`方法尝试立即停止所有正在执行的线程。最后再次使用`awaitTermination()`方法等待一段时间，以确保所有线程都被终止。如果在最后的等待时间内仍有线程未被终止，可以根据实际情况进行处理。