java newfixedthreadpool怎样关闭线程池 - 问答

要关闭Java中的FixedThreadPool，您需要调用shutdown()或shutdownNow()方法。这两个方法的主要区别在于它们处理正在执行任务的方式。

shutdown(): 这个方法将启动线程池的关闭过程。已经提交的任务将继续执行，但不再接受新任务。这个方法不会立即关闭线程池，而是等待所有任务完成后才关闭。

ExecutorService executorService = Executors.newFixedThreadPool(5);
// 提交并执行任务...
executorService.shutdown(); // 关闭线程池

shutdownNow(): 这个方法将尝试立即停止所有正在执行的任务，并返回尚未开始执行的任务列表。这个方法无法保证能够立即停止所有任务，因为它们可能在执行过程中不响应中断。

ExecutorService executorService = Executors.newFixedThreadPool(5);
// 提交并执行任务...
List<Runnable> unfinishedTasks = executorService.shutdownNow(); // 立即关闭线程池，返回未完成任务列表

在关闭线程池后，您可以使用awaitTermination()方法等待所有任务完成。这个方法会阻塞当前线程，直到所有任务完成或超时（可选）。

executorService.shutdown();
try {
    if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
        executorService.shutdownNow();
    }
} catch (InterruptedException e) {
    executorService.shutdownNow();
}

这样，您就可以确保线程池被正确关闭，所有任务都已完成，或者被取消。

0 赞

0 踩