Java線程池提供了一種優(yōu)雅地停止正在執(zhí)行的任務(wù)的方法,可以通過調(diào)用shutdown()
方法來停止線程池的執(zhí)行,并等待所有已提交的任務(wù)執(zhí)行完成。具體步驟如下:
shutdown()
方法來停止線程池的執(zhí)行。ExecutorService executor = Executors.newFixedThreadPool(10);
executor.shutdown();
awaitTermination()
方法來等待所有已提交的任務(wù)執(zhí)行完成,或者指定一個超時時間。try {
if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
executor.shutdownNow(); // 如果超時,強(qiáng)制停止所有正在執(zhí)行的任務(wù)
}
} catch (InterruptedException e) {
executor.shutdownNow(); // 如果發(fā)生異常,強(qiáng)制停止所有正在執(zhí)行的任務(wù)
}
在調(diào)用awaitTermination()
方法時,可以指定一個超時時間,如果超過了指定的時間,但仍有任務(wù)未執(zhí)行完成,則返回false。此時,可以調(diào)用shutdownNow()
方法來強(qiáng)制停止所有正在執(zhí)行的任務(wù)。
isShutdown()
和isTerminated()
方法。Runnable task = new Runnable() {
public void run() {
// 執(zhí)行任務(wù)邏輯
if (executor.isShutdown() && !executor.isTerminated()) {
// 執(zhí)行清理操作
}
}
};
注意,調(diào)用shutdown()
方法只會停止線程池接受新的任務(wù),并不會停止已經(jīng)提交的任務(wù)的執(zhí)行。要停止正在執(zhí)行的任務(wù),需要配合awaitTermination()
和shutdownNow()
方法使用。