假设场景：
我有一个守护线程负责一些 I/O，主线程完成并返回，JVM 决定终止我的守护线程。
它是如何做到的？打断？敲定？如何编码我的守护线程，以便它在终止时做出优雅的反应？
【问题讨论】：
标签： java multithreading jvm daemon
我只是写了以下代码作为测试：
public class DaemonThreadPlay {
public static void main(String [] args) {
Thread daemonThread = new Thread() {
public void run() {
while (true) {
try {
System.out.println("Try block executed");
Thread.sleep(1000l);
} catch (Throwable t) {
t.printStackTrace();
}
}
}
@Override
public void finalize() {
System.out.println("Finalize method called");
}
};
daemonThread.setDaemon(true);
daemonThread.start();
try {
Thread.sleep(2500l);
} catch (Throwable t) {
//NO-OP
}
}
}
我在守护线程的 catch 块和 finalize 方法中设置了断点。即使执行了 try 块，也没有到达断点。显然这段代码存在同步/计时问题，但我认为我们可以安全地得出结论，守护线程不会在关闭时中断，也不一定会调用它们的 finalize() 方法。
您始终可以向 JVM 运行时添加关闭挂钩：
Thread shutdownHook = ... // construct thread that somehow
// knows about all the daemon threads
Runtime.getRuntime().addShutdownHook(shutdownHook);
您的关闭挂钩显然可以执行“优雅”关闭所需的任何任务。
【讨论】：
System.gc()并且没有设置JVM选项-XX:+DisableExplicitGC，那么守护线程将会退出。这意味着垃圾收集器负责在所有用户线程完成后关闭守护线程。
我认为你误解了守护线程是什么。
见what is a daemon thread in java
总而言之，它基本上意味着守护线程不应该进行任何 I/O 或持有任何资源。如果您违反了这个基本规则，那么您的线程不符合成为守护线程的条件。
添加关闭挂钩是确保您的代码在 JVM 终止之前被调用的标准方法，但即使这样也不能 100% 保证 - 例如，您的 JVM 可能会崩溃，让操作系统以一种方式整理资源保护操作系统，但很可能使您的应用程序处于不一致/错误状态。
系统检查点和恢复机制可以追溯到软件的早期（例如操作系统和批处理操作），不幸的是，这个*不断被重新发明，因为没有解决这个问题的“银弹”方法 (API)以足够通用的方式解决问题。
【讨论】：
AFAIK，守护线程并不是真正用于主流 I/O 工作。如果所有线程都完成，JVM 可能会突然关闭所有守护线程。根据您的要求，可能的解决方法是创建一个 ExecutorService，如下所示：
ExecutorService execPool = Executors.newSingleThreadExecutor(new ThreadFactory() {
@Override
public Thread newThread(Runnable runnable) {
Thread thread = Executors.defaultThreadFactory().newThread(runnable);
thread.setDaemon(true);
return thread;
}
});
从 Shutdown hook 调用 executorservice 关闭方法。
Runtime.getRuntime().addShutdownHook(....)
【讨论】：
Executors.defaultThreadFactory() 的调用只返回一个new DefaultThreadFactory()
使用中断和加入：
class Daemon extends Thread {
public void run() {
while (true) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
System.out.println(e);
break;
}
}
System.out.println("exit run()");
}
}
public class So8663107 {
public static void main(String[] arguments) throws InterruptedException {
System.out.println(Thread.activeCount());
Daemon daemon = new Daemon();
daemon.setDaemon(true);
daemon.start();
Thread.sleep(2500);
System.out.println(Thread.activeCount());
daemon.interrupt();
daemon.join();
System.out.println(Thread.activeCount());
}
}
【讨论】：