难以理解何时执行关闭钩子以及如何终止执行器服务

Question

我正在尝试运行一个基于scheduleAtFixedRateExecutorService的程序。 我使用此服务来替换虚拟while循环。 全局思想是首先让一个ExecutorService(调度程序)执行一个Runnable(可运行)。然后，出于某种原因，可运行对象可能会也可能不会在其他ExecutorService(任务者)上安排任务。 现在的问题是：

• 当我停止程序时，我应该如何停止所有这些线程？

我已经尝试了一下，但找不到合适的解决方案。 我尝试了两件事：DaemonThread，ShutdownHook守护进程线程不是我想要的，我希望调度程序继续运行，直到我停止程序。 乍一看，ShutdownHook 不是一个好的解决方案，但经过一些研究，它似乎有效。

• 我只是不明白为什么。

问题是，如果我使用命令mvn exec:java -Dexec.mainClass="com.goodbook.App"执行代码并使用Ctrl+C停止它，则会运行 ShutdownHook，但是如果我在 IDE 中运行 java 代码(VScode)并使用调试器工具停止它，它就不会执行。 所以还有两个问题：

• 为什么要执行ShutdownHook？
• 为什么使用命令行运行和使用 IDE 运行之间的行为不同

首先，我给你两段代码：App和Task类。

---

应用.java

package com.goodbook;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
class ShutdownHook {
private static final Logger logger = LoggerFactory.getLogger(ShutdownHook.class);
public void attachShutDownHook(ScheduledExecutorService scheduler, ScheduledExecutorService tasker) {
logger.info("attaching shutdown hook");
Runtime.getRuntime().addShutdownHook(new Thread() {
@Override
public void run() {
scheduler.shutdown();
tasker.shutdown();
logger.info("shutdown hook runned");
logger.info("scheduler is down : "+scheduler.isShutdown());
logger.info("tasker is down : "+tasker.isShutdown());
}
});
}
}
public class App 
{
private static final Logger logger = LoggerFactory.getLogger(App.class);
public static void main( String[] args )
{   
logger.info("starting program");
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(0);
ScheduledExecutorService tasker = Executors.newScheduledThreadPool(0);
ShutdownHook shutdown = new ShutdownHook();
shutdown.attachShutDownHook(scheduler, tasker);
Task t = new Task("task1");
Runnable  runnable = () -> {
logger.info("running Tasker 1");
if(!t.isPlanified()){
logger.info("unplanified task found "+t.getName());
logger.info("planning...");
tasker.schedule(t, 1000, TimeUnit.MILLISECONDS);
t.setPlanified(true);
}
};
logger.info("scheduling tasks");
scheduler.scheduleAtFixedRate(runnable, 0, 1000, TimeUnit.MILLISECONDS);
} 
}

任务.java

package com.goodbook;
import java.util.concurrent.atomic.AtomicBoolean;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class Task implements Runnable {
private static final Logger logger = LoggerFactory.getLogger(App.class);
String name;
AtomicBoolean planified = new AtomicBoolean(false);
public Task(String name){
this.name = name;
}
@Override
public void run(){
logger.info(name+" run");
planified.set(false);
}
public Boolean isPlanified(){
return planified.get();
}
public void setPlanified(Boolean b){
planified.set(b);
}
public String getName(){
return name;
}
}

在使用 VScode 运行并使用调试器工具停止执行的情况下，日志文件的结尾：

INFO    2019-04-06 16:35:54,121 [pool-1-thread-1] com.goodbook.App  - planning...
INFO    2019-04-06 16:35:55,121 [pool-1-thread-1] com.goodbook.App  - Running Tasker 1
INFO    2019-04-06 16:35:55,121 [pool-2-thread-4] com.goodbook.TestTask  - task1 run
INFO    2019-04-06 16:35:56,121 [pool-1-thread-1] com.goodbook.App  - Running Tasker 1
INFO    2019-04-06 16:35:56,121 [pool-1-thread-1] com.goodbook.App  - Unplanified task found task1
INFO    2019-04-06 16:35:56,121 [pool-1-thread-1] com.goodbook.App  - planning...

使用mvn exec:java -Dexec.mainClass="com.goodbook.App"运行并使用Ctrl+C停止执行的情况下日志文件的结尾：

INFO    2019-04-06 16:59:09,686 [pool-1-thread-1] com.goodbook.App  - running Tasker 1
INFO    2019-04-06 16:59:09,688 [pool-2-thread-1] com.goodbook.Task  - task1 run
INFO    2019-04-06 16:59:10,686 [pool-1-thread-1] com.goodbook.App  - running Tasker 1
INFO    2019-04-06 16:59:10,686 [pool-1-thread-1] com.goodbook.App  - unplanified task found task1
INFO    2019-04-06 16:59:10,687 [pool-1-thread-1] com.goodbook.App  - planning...
INFO    2019-04-06 16:59:11,686 [pool-1-thread-1] com.goodbook.App  - running Tasker 1
INFO    2019-04-06 16:59:11,687 [pool-2-thread-2] com.goodbook.Task  - task1 run
INFO    2019-04-06 16:59:12,641 [Thread-1] com.goodbook.ShutdownHook$1  - shutdown hook runned
INFO    2019-04-06 16:59:12,642 [Thread-1] com.goodbook.ShutdownHook$1  - scheduler is down : true
INFO    2019-04-06 16:59:12,642 [Thread-1] com.goodbook.ShutdownHook$1  - tasker is down : true

我真的需要解决这些问题的帮助，我不是 java 开发人员：s

Answer 1

关闭钩子在 JVM 关闭时被调用;请参阅Runtime.addShutdownHook中的 JavaDoc 类。但是，从调试器终止运行不是关闭。

通常退出

当最后一个非守护程序线程退出，或者通过代码调用System.exit()，或者在命令行上按下 CTRL-C 时(或者程序被发送终止信号，例如使用任务管理器)，然后执行关闭钩子，一旦它们完成，JVM 就会关闭。

从调试器退出

如果在调试期间终止程序，然后按"停止"，IDE将立即中止应用程序。没有机会运行关闭挂钩。这通常是正确的做法;调试时，您通常只想终止正在运行的任何内容。

调试时正常退出

如果你想要一种方法在调试时运行关闭钩子，有很多方法;一种是通过代码调用System.exit();这将触发钩子。在这个相关的问题中，他们在调用 system.exit 之前等待按键事件。

---

关于

当我停止程序时，我应该如何停止所有这些线程？

同样，你可以调用System.exit()这样程序就会终止，即使非 deamon 线程在执行过程中(这不是真的干净); 但更好的方法是给每个线程一个下疳来正常终止 - 例如。 如果线程正在运行无限循环，它可以定期检查(易失性)shutdown变量， 并在变量设置时返回(通过代码)。(shutdown变量本身应该由关闭钩子设置)