Java中如何保证业务线程的完整性

以前在开发时只知道依靠数据库事务来保证程序关闭时数据的完整性。

但有些时候一个业务上要求的原子操作&＃xff0c;不一定只包括数据库&＃xff0c;比如外部接口或者消息队列。此时数据库事务就无能为力了。

这时我们可以依靠java提供的一个工具方法&＃xff1a;java.lang.Runtime.addShutdownHook(Thread hook)

addShutdownHook方法可以加入一个钩子&＃xff0c;在程序退出时触发该钩子。

(退出是指ctrl&＃43;c或者kill -15&＃xff0c;但如果用kill -9 那是没办法的&＃xff0c;具体有关kill的signal机制有篇大牛的文章《Linux 信号signal处理机制》)

钩子做什么操作都可以&＃xff0c;甚至可以循环检查某个线程的状态&＃xff0c;直到业务线程正常退出&＃xff0c;再结束钩子程序就可以保证业务线程的完整性

例子程序如下&＃xff1a;

实例程序在执行过程中按下ctrl -c或者 kill -15&＃xff0c;由于钩子程序的循环检测&＃xff0c;能够保证线程执行完毕后&＃xff0c;程序才关闭。

1/**2* Created by IntelliJ IDEA.3* User: Luo4* Date: 13-7-115* Time: 下午3:126*/78publicclassTestShutdownHook {910/**11* 测试线程&＃xff0c;用于模拟一个原子操作12*/13privatestaticclassTaskThreadextendsThread {14&＃64;Override15publicvoidrun() {16System.out.println("thread begin ...");17TestShutdownHook.sleep(1000);18System.out.println("task 1 ok ...");19TestShutdownHook.sleep(1000);20System.out.println("task 2 ok ...");21TestShutdownHook.sleep(1000);22System.out.println("task 3 ok ...");23TestShutdownHook.sleep(1000);24System.out.println("task 4 ok ...");25TestShutdownHook.sleep(1000);26System.out.println("task 5 ok ...");2728System.out.println("thread end\n\n");29}30}3132/**33* 注册hook程序&＃xff0c;保证线程能够完整执行34*&＃64;paramcheckThread35*/36privatestaticvoidaddShutdownHook(finalThread checkThread) {37//为了保证TaskThread不在中途退出&＃xff0c;添加ShutdownHook38Runtime.getRuntime().addShutdownHook(newThread() {39publicvoidrun() {40System.out.println("收到关闭信号&＃xff0c;hook起动&＃xff0c;开始检测线程状态 ...");41//不断检测一次执行状态&＃xff0c;如果线程一直没有执行完毕&＃xff0c;超时后&＃xff0c;放弃等待      \42for(inti &＃61; 0; i <100; i&＃43;&＃43;) {43if(checkThread.getState() &＃61;&＃61;State.TERMINATED) {44System.out.println("检测到线程执行完毕&＃xff0c;退出hook");45return;46}47TestShutdownHook.sleep(100);48}49System.out.println("检测超时&＃xff0c;放弃等待&＃xff0c;退出hook&＃xff0c;此时线程会被强制关闭");50}51});52}535455privatestaticvoidsleep(longmillis) {56try{57Thread.sleep(millis);58}catch(InterruptedException e) {59e.printStackTrace();60}61}6263publicstaticvoidmain(String[] args)throwsInterruptedException {64finalTaskThread taskThread &＃61;newTaskThread();65//为了保证TaskThread不在中途退出&＃xff0c;添加ShutdownHook66addShutdownHook(taskThread);67//执行TaskThread68taskThread.start();69}7071}