难以理解何时执行shutdown hook以及如何终止ExecutorService

Question

我正在尝试运行基于scheduleAtFixedRate ExecutorService的程序。我使用此服务来替换虚拟while循环。全球的想法是首先执行一个ExecutorService（调度程序）执行Runnable（可运行）。然后，由于某种原因，可运行的可能会或可能不会在其他ExecutorService（任务者）上安排任务。现在的问题是：

• 当我停止程序时，我怎么想停止所有这些线程呢？

我做了一些实验，找不到合适的解决方案。我尝试了两件事：DaemonThread，ShutdownHook守护程序线程不是我正在寻找的，我希望调度程序继续运行，直到我停止程序。 ShutdownHook初看起来并不是一个好的解决方案，但经过一些研究似乎有效。

• 我只是不明白为什么。

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

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

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

---

app.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);
  } 
}

task.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 dev：s

Answer 1

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

Usual exit

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

Exit from debugger

如果在调试期间终止程序，并按“停止”，IDE会立即中止您的应用程序。没有机会运行关机钩子。这通常是正确的做法;在调试时，你通常想要杀死正在运行的任何东西。

Exiting gracefully while debugging

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

---

关于

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

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