在我的代碼中，我使用CompletionService和ExecutorService來啟動一堆Thread來執(zhí)行某些任務(wù)(這可能需要很長時間) . 所以我有一個創(chuàng)建ExecutorService和CompletionService的方法，然后開始提交線程然后獲取結(jié)果 . 我想添加一個關(guān)閉鉤子，以便優(yōu)雅地關(guān)閉執(zhí)行程序(我知道可能我應(yīng)該處理釋放資源而不是 Actuator 關(guān)閉但在我的情況下每個線程都有自己的資源，所以優(yōu)雅地關(guān)閉它們可以是一個很好的解決方案我假設(shè)) .

因此我編寫以下代碼

public Class myClass{

...

private CompletionService completion;

final long SHUTDOWN_TIME = TimeUnit.SECONDS.toSeconds(10);

...

public Message executeCommand(Message request){

final ExecutorService executor = Executors.newFixedThreadPool(30);

completion = new ExecutorCompletionService(executor);

....//submit and take results

Runtime.getRuntime().addShutdownHook(new Thread(){

@Override

public void run() {

logger.debug("Shutting down executor");

try {

if (!executor.awaitTermination(SHUTDOWN_TIME, TimeUnit.SECONDS)) {

logger.debug("Executor still not terminate after waiting time...");

List notExecuted= executor.shutdownNow();

logger.debug("List of dropped task has size " + droppedTasks.size());

}

}catch(InterruptedException e){

logger.error("",e);

}

}

});

}

}

您認為這是一個合理的解決方案，還是使用本地類注冊和取消注冊關(guān)閉鉤子是不安全的？

提前致謝

問候

總結(jié)

以上是生活随笔為你收集整理的java 自定义 钩子_Java添加关闭钩子里面的方法的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。