java 钩子线程_java-钩子线程
在线上Java程序中经常遇到进程程挂掉,一些状态没有正确的保存下来,这时候就需要在JVM关掉的时候执行一些清理现场的代码。Java中得ShutdownHook提供了比较好的方案。
JDK在1.3之后提供了Java Runtime.addShutdownHook(Thread hook)方法,可以注册一个JVM关闭的钩子,这个钩子可以在以下几种场景被调用:
1)程序正常退出
2)使用System.exit()
3)终端使用Ctrl+C触发的中断
4)系统关闭
5)使用Kill pid命令干掉进程
注:在使用kill -9 pid是不会JVM注册的钩子不会被调用。
在JDK中方法的声明:
public void addShutdownHook(Thread hook)
参数
hook – 一个初始化但尚未启动的线程对象,注册到JVM钩子的运行代码。
异常
IllegalArgumentException – 如果指定的钩已被注册,或如果它可以判定钩已经运行或已被运行
IllegalStateException – 如果虚拟机已经是在关闭的过程中
SecurityException – 如果存在安全管理器并且它拒绝的RuntimePermission(“shutdownHooks”)
代码示例:
使用Timer模拟一个工作线程,该线程重复工作十次,使用System.exit()退出,在清理现场代码CleanWorkThread 中,取消timer运行,并输出必要的日志信息。
package com.netease.test.java.lang;
import java.util.Timer;
import java.util.TimerTask;
import java.util.concurrent.atomic.AtomicInteger;
/** * Date: 14-6-18 * Time: 11:01 * 测试ShutdownHook */
public class TestShutdownHook {
//简单模拟干活的
static Timer timer = new Timer("job-timer");
//计数干活次数
static AtomicInteger count = new AtomicInteger(0);
/** * hook线程 */
static class CleanWorkThread extends Thread{
@Override
public void run() {
System.out.println("clean some work.");
timer.cancel();
try {
Thread.sleep(2 * 1000);//sleep 2s
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
public static void main(String[] args) throws InterruptedException {
//将hook线程添加到运行时环境中去
Runtime.getRuntime().addShutdownHook(new CleanWorkThread());
System.out.println("main class start ..... ");
//简单模拟
timer.schedule(new TimerTask() {
@Override
public void run() {
count.getAndIncrement();
System.out.println("doing job " + count);
if (count.get() == 10) { //干了10次退出
System.exit(0);
}
}
}, 0, 2 * 1000);
}
}
当发生了System.exit(int)时,希望在系统退出前,执行一点任务来做一些资源方面的回收操作,ShutdownHook可以达到这个目的,它利用hook思路来实现,有些时候也把它叫作“钩子“。
假如在系统中通过Runtime.getRuntime().exec()或new ProcessBuilde()启动了子进程(Process),这个子进程一直在运行中,在当前进程退出时,子进程未必会退出,但此时业务上希望将它退出,就可以利用这一点。例如可以这样写:
Runtime.getRuntime().addShutdownHook()
{
new Thread()
{
public void run()
{
processer.destroy();
}
}
}
这里需要注意的是,传入参数是通过new Thread()创建的线程对象,在Java进程调用exit()时,会调用该线程对象的start()方法将其运行起来,所以不要手工先启动了。另外,这种回调线程就不要设定为死循环程序,否则就无法退出了。
再简单阐述下原理,大家也可以自行分析源码得到答案。
java.lang包下有一个Shutdown类,提供了一个Runnable []hooks数组,数组的长度为10,也就是最多定义10个hook(这与程序写入多少个线程回调没有关系,下面会介绍,提供add()方法来注册新的hook对象)
在java.lang.ApplicationShutdownHooks的static匿名块中,通过add()方法注册了一个hook,在run()方法内部的静态方法runHooks(),它内部用一个IdentityHashMap来存放hook信息,可以通过add()方法来添加,而程序中定义的回调线程都放在了这里,它自身用hook的形式存放在于hooks列表中,如下所示:
class ApplicationShutdownHooks
{
static
{
Shutdown.add(1 /* shutdown hook invocation order*/,
new Runnable()
{
public void run()
{
runHooks();
}
}
);
}
}
当调用Runnable.getRunnable().addShutdownHook(Thread)方法时,会间接调用ApplicationShutdownHooks.add(Thread)将线程放到IdentityHashMap中。
当调用System.exit(int)方法时,会间接调用Shutdown.exit(int)方法,再调用sequence()->runHooks()方法,调用如下所示:
/* Run all registered shutdown hooks */
private static void runHooks() {
for (int i=0; i < MAX_SYSTEM_HOOKS; i++) {
try {
Runnable hook;
synchronized (lock) {
// acquire the lock to make sure the hook registered during
// shutdown is visible here.
currentRunningHook = i;
hook = hooks[i];
}
if (hook != null) hook.run();
} catch(Throwable t) {
if (t instanceof ThreadDeath) {
ThreadDeath td = (ThreadDeath)t;
throw td;
}
}
}
}
循环中的一个hook对象就是由ApplicationShutdownHooks的匿名块定义的,因此会调用ApplicationShutdownHooks类的run()方法,再调用它的runHooks()方法,这个runHooks()方法如下所示:
/* Iterates over all application hooks creating a new thread for each
* to run in. Hooks are run concurrently and this method waits for
* them to finish.
*/
static void runHooks() {
Collection threads;
synchronized(ApplicationShutdownHooks.class) {
threads = hooks.keySet();
hooks = null;
}
for (Thread hook : threads) {
hook.start();
}
for (Thread hook : threads) {
try {
hook.join();
} catch (InterruptedException x) { }
}
}
从这个方法中取出所有的Thread,然后将线程启动起来,最后通过join()方法等待各个线程结束动作。换句话说,在线程关闭前,对多个回调任务的处理方式是每个任务单独有一个线程处理,而不是所有的任务在一个线程中串行处理。
Runtime.getRuntime().removeShutdownHook用于删除一个钩子线程。
java 钩子线程_java-钩子线程相关推荐
- java 线程组和线程_Java多线程 线程组原理及实例详解
线程组 线程组可以批量管理线程和线程组对象. 一级关联 例子如下,建立一级关联. public class MyThread43 implements Runnable{ public void ru ...
- java 线程中创建线程_java – 在线程中创建线程 – 良好的做法?
参见英文答案 > Threads within threads in Java? 4个 在线程中启动线程是一种好习惯吗?我搜 ...
- java中断线程_Java中断线程的方法
使用interrupt()中断线程 当一个线程运行时,另一个线程可以调用对应的Thread对象的interrupt()方法来中断它,该方法只是在目标线程中设置一个标志,表示它已经被中断,并立即返回.这 ...
- java阻塞超时_JAVA防线程阻塞(超时控制)
2.[代码]TimeoutThread /** * java线程超时控制的实现 * * 超时控制一般使用阻塞时间比较长的操作上,有可能是和远程数据库的连接,也有可能是网络下载,在程序超时后, 往往需要 ...
- java自定义线程_Java自定义线程池详解
自定义线程池的核心:ThreadPoolExecutor 为了更好的控制多线程,JDK提供了一套线程框架Executor,帮助开发人员有效的进行线程控制,其中在java.util.concurrent ...
- java 多线程池_Java ThreadPoolExecutor线程池 同时执行50个线程
最近项目上有个需求,需要从FTP服务器中下载大批量的数据文件,然后解析该数据文件进行入库,数据库为oracle,最后在通过web工程,以报表和图表的形式进行展现. 这些批量的数据文件为纯文本文件,每天 ...
- java 添加等待时间_Java中线程等待特定时间的最有效方法 - java
我知道这个问题here,但是我有一个稍微不同的问题.如果我希望自己通过各种Thread方法(而不是通过实用程序类或Quartz)手动编码某个线程在特定时间的运行,那么最有效(就开销而言)进行编码. 我 ...
- java多线程通信_Java多线程-线程通信
原标题:Java多线程-线程通信 通信的方式 要想实现多个线程之间的协同,如:线程执行先后顺序.获取某个线程执行的结果等等.涉及到线程之间的相互通信,分为下面四类: 文件共享 网络共享 共享变量 JD ...
- java 多线程 交替_java 多线程–线程交替
要求: 借助同步机制,sleep()方法,join()方法,实现动画显示: 甲线程:1.3.5.7.9 乙线程:2.4.6.8.10 丙线程:a.b.c.d.e main()线程输出:线程开始,线程结 ...
- java 事务管理 子父线程_java父线程子线程(转)
问:在父线程中New了一个子线程,想在停止父线程时也停止子线程,应该怎么做? 答: 从某种程度上讲,做不到. 不管是父线程还是子线程,这只不过是在运行时谁建了谁时用的,一旦所谓的字线程被启动,这两个线 ...
最新文章
- [linux]windows无法访问samba的安全性问题(关闭selinux)
- 31天重构学习笔记3. 提升方法
- URAL - 1114-Boxes (分步乘法原理)
- word List18
- VUE : 双重 for 循环写法、table 解析任意 list 、万能表格组件、解析一维数组、动态生成 table 所有数据
- 弱鸡儿长乐爆肝旅Day8
- Python菜鸟入门:day19编程学习
- 小红书下拉词是什么?小红薯下拉框怎么做?下拉词框如何应用?
- 《自拍教程47》Python adb重启设备100次
- 渗透测试流程-全(仅供学习,知识分享)
- 计算机病毒是指______.,计算机病毒是指
- linux 运维工程师必备技能
- 你可能没听过的11个Python库
- 卡通农场服务器无响应是怎么回事,卡通农场新买的平板打不开的解决方法
- 量化干货 | 机器学习能否助力风险投资?
- [论文翻译]A review on image segmentation techniques
- 为什么iPhone4到iPhone4S坚持使用512MB内存 详解 给力
- 数学建模——多元统计分析例题及程序
- 什么是量子霸权?我们如何才能实现它?
- drtek收音机使用说明_德劲1103收音机【简易操作指南】.【使用说明书】.高清版...