java - 难以理解关闭 Hook 何时执行以及如何终止 ExecutorService

Question

我正在尝试运行一个基于 scheduleAtFixedRate 的程序ExecutorService .我使用此服务来替换虚拟 while环形。全局的想法是首先有一个 ExecutorService (调度程序)执行 Runnable (可运行)。然后，出于某种原因，runnable 可能会或可能不会在另一个 ExecutorService 上安排任务(任务者)。现在的问题是:

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

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

• 我只是不明白为什么。

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

• 为什么是 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

关闭 Hook 在 JVM 时调用正在关闭；在 Runtime.addShutdownHook 查看类 JavaDoc .但是从调试器终止运行不是关闭。

正常退出

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

退出调试器

如果在调试过程中终止程序，并按“停止”，IDE 立即中止您的应用。没有机会运行关闭 Hook 。这通常是正确的做法；调试时，您通常希望杀死任何正在运行的东西。

调试时优雅退出

如果您想在调试时运行关闭 Hook ，有多种方法；一个在打电话System.exit()通过代码；这将触发钩子(Hook)。在 this相关问题，他们在调用 system.exit 之前等待按键事件。

---

关于

how am I supposed to stop all these Threads when I stop the program ?

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