要关闭Java中的FixedThreadPool,您需要调用shutdown()
或shutdownNow()
方法。这两个方法的主要区别在于它们处理正在执行任务的方式。
shutdown()
: 这个方法将启动线程池的关闭过程。已经提交的任务将继续执行,但不再接受新任务。这个方法不会立即关闭线程池,而是等待所有任务完成后才关闭。
ExecutorService executorService = Executors.newFixedThreadPool(5); // 提交并执行任务... executorService.shutdown(); // 关闭线程池
shutdownNow()
: 这个方法将尝试立即停止所有正在执行的任务,并返回尚未开始执行的任务列表。这个方法无法保证能够立即停止所有任务,因为它们可能在执行过程中不响应中断。
ExecutorService executorService = Executors.newFixedThreadPool(5); // 提交并执行任务... ListunfinishedTasks = executorService.shutdownNow(); // 立即关闭线程池,返回未完成任务列表
在关闭线程池后,您可以使用awaitTermination()
方法等待所有任务完成。这个方法会阻塞当前线程,直到所有任务完成或超时(可选)。
executorService.shutdown(); try { if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) { executorService.shutdownNow(); } } catch (InterruptedException e) { executorService.shutdownNow(); }
这样,您就可以确保线程池被正确关闭,所有任务都已完成,或者被取消。