更新時間:2023-06-19 來源:黑馬程序員 瀏覽量:
在Java中,線程池的關閉方式有三種:shutdown()、shutdownNow()和awaitTermination()。
·該方法會平滑地關閉線程池,不再接受新的任務提交。
·它會等待所有已提交的任務執(zhí)行完畢,包括已經在等待隊列中的任務。
·如果線程池已經關閉,則調用該方法沒有任何效果。
ExecutorService executor = Executors.newFixedThreadPool(5); // 執(zhí)行任務... executor.shutdown(); // 關閉線程池 // 等待線程池中的任務執(zhí)行完畢 try { executor.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS); } catch (InterruptedException e) { // 處理中斷異常 }
·該方法會強制關閉線程池,嘗試中斷正在執(zhí)行的任務,并返回等待執(zhí)行的任務列表。
·它會立即停止線程池的運行,不再處理等待隊列中的任務。
·如果線程池已經關閉,則調用該方法沒有任何效果。
ExecutorService executor = Executors.newFixedThreadPool(5); // 執(zhí)行任務... List<Runnable> unprocessedTasks = executor.shutdownNow(); // 強制關閉線程池 // 處理未執(zhí)行的任務 for (Runnable task : unprocessedTasks) { // 處理未執(zhí)行的任務... }
·該方法用于等待線程池中的任務執(zhí)行完畢,或者在指定的時間內等待任務執(zhí)行完畢。
·它會阻塞當前線程,直到滿足以下條件之一:所有任務執(zhí)行完畢、超過指定的等待時間、當前線程被中斷。
這些關閉方式可以根據具體需求選擇合適的方法,shutdown()和awaitTermination()提供了一種平滑關閉線程池的方式,而shutdownNow()則提供了一種立即停止線程池的方式。
ExecutorService executor = Executors.newFixedThreadPool(5); // 執(zhí)行任務... executor.shutdown(); // 關閉線程池 // 等待線程池中的任務執(zhí)行完畢,最多等待1小時 try { if (!executor.awaitTermination(1, TimeUnit.HOURS)) { // 執(zhí)行超時處理 } } catch (InterruptedException e) { // 處理中斷異常 }