在正式理解这个概念前,先把 守护线程 与 守护进程 这二个极其相似的说法区分开,守护进程通常是为了防止某些应用因各种意外原因退出,而在后*立运行的系统服务或应用程序。 比如:我们开发了一个邮件发送程序,一直不停的监视队列池,发现有待发送的邮件,就将其发送出去。如果这个程序挂了(或被人误操作关了),邮件就不发出去了,为了防止这种情况,再开发一个类似windows 系统服务的应用,常驻后台,监制这个邮件发送程序是否在运行,如果没运行,则自动将其启动。
而我们今天说的java中的守护线程(Daemon Thread) 指的是一类特殊的Thread,其优先级特别低(低到甚至可以被JVM自动终止),通常这类线程用于在空闲时做一些资源清理类的工作,比如GC线程,如果JVM中所有非守护线程(即:常规的用户线程)都结束了,守护线程会被JVM中止,想想其实也挺合理,没有任何用户线程了,自然也不会有垃圾对象产生,GC线程也没必要存在了。
实际开发中,也可以手动将线程设置为Daemon Thread,只有一个限制:必须在线程的start方法设置,见下面的示例:
package test; public class Program { public static void main(String[] args) {
TestThread t1 = new TestThread();
t1.setDaemon(true);
t1.start();
} private static class TestThread extends Thread {
public void run() {
System.out.println("test");
}
}
}
由于t1设置成Daemon Thread了,运行后,main进程马上就结束,此时没有用户进程在运行,守护进程默认是不执行的,因此运行后,没有任何输出结果,符合我们刚才的解释。
注:在idea等集成IDE环境下测试时,如果多次点击Run按钮,可能会发现第二次运行时,偶尔也会输出test,估计是ide里上次运行后的java进程并未完全退出,可以手动把windows进程中的所有java.exe进程干掉再测试。
如果把t1.setDaemon(true);这一行注释掉,就会输出test了。
另外,如果把main函数最后加一行阻塞的代码,比如:
public static void main(String[] args) throws IOException {
TestThread t1 = new TestThread();
t1.setDaemon(true);
t1.start();
System.in.read();
}
加了一行System.in.read()后,再运行,会发现test会输出,这是因为main这个用户线程被阻塞了,JVM发现有用户进程在运行,守护进程才能机会被执行。
再来一个复杂点的示例:
假设有二个线程,一个是常规的用户线程,不停写入日志,另一个是守护线程,在空闲时清理日志(仅保留最近的5条日志)
package test; import java.io.IOException;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue; public class Program { private static int queueCapacity = 10;
private static BlockingQueue<String> logQueue = new ArrayBlockingQueue<String>(queueCapacity); public static void main(String[] args) throws IOException { LogWriter writer = new LogWriter();
LogCleaner cleaner = new LogCleaner();
cleaner.setDaemon(true); writer.start();
cleaner.start();
} /**
* 模拟不停写日志(直到队列写满)
*/
private static class LogWriter extends Thread {
public void run() {
for (int i = 0; i < queueCapacity; i++) {
try {
logQueue.put("" + i);
System.out.println("日志已写入,当前日志内容:" + logQueue);
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
} /**
* 模拟在空闲时清理日志(仅保留5条日志)
*/
private static class LogCleaner extends Thread {
public void run() {
while (true) {
if (logQueue.size() > 5) {
try {
logQueue.take();
System.out.println("多余日志被清理,当前日志内容:" + logQueue);
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
}
运行结果:
日志已写入,当前日志内容:[]
日志已写入,当前日志内容:[, ]
日志已写入,当前日志内容:[, , ]
日志已写入,当前日志内容:[, , , ]
日志已写入,当前日志内容:[, , , , ]
日志已写入,当前日志内容:[, , , , , ]
多余日志被清理,当前日志内容:[, , , , ]
日志已写入,当前日志内容:[, , , , , ]
多余日志被清理,当前日志内容:[, , , , ]
日志已写入,当前日志内容:[, , , , , ]
多余日志被清理,当前日志内容:[, , , , ]
日志已写入,当前日志内容:[, , , , , ]
多余日志被清理,当前日志内容:[, , , , ]
日志已写入,当前日志内容:[, , , , , ]
多余日志被清理,当前日志内容:[, , , , ]
参考文章: