热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

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

在开发中,有时候一个业务上要求的原子操作不仅仅包括数据库,还可能涉及外部接口或者消息队列。此时,传统的数据库事务无法满足需求。本文介绍了Java中如何利用java.lang.Runtime.addShutdownHook方法来保证业务线程的完整性。通过添加钩子,在程序退出时触发钩子,可以执行一些操作,如循环检查某个线程的状态,直到业务线程正常退出,再结束钩子程序。例子程序展示了如何利用钩子来保证业务线程的完整性。

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

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

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

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

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

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

例子程序如下:

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

937a03f92563

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}

937a03f92563



推荐阅读
  • 关于进程的复习:#管道#数据的共享Managerdictlist#进程池#cpu个数1#retmap(func,iterable)#异步自带close和join#所有 ... [详细]
  • Android异步处理一:使用Thread+Handler实现非UI线程更新UI界面Android异步处理二:使用AsyncTask异步更新UI界面Android异步处理三:Handler+Loope ... [详细]
  • 题目描述:计算从起点到终点的最小能量消耗。如果下一个单元格的风向与当前单元格相同,则消耗为0,否则为1。共有8个可能的方向。 ... [详细]
  • Redis:缓存与内存数据库详解
    本文介绍了数据库的基本分类,重点探讨了关系型与非关系型数据库的区别,并详细解析了Redis作为非关系型数据库的特点、工作模式、优点及持久化机制。 ... [详细]
  • 前言:由于Android系统本身决定了其自身的单线程模型结构。在日常的开发过程中,我们又不能把所有的工作都交给主线程去处理(会造成UI卡顿现象)。因此,适当的创建子线程去处理一些耗 ... [详细]
  • 作为一名Android应用开发新手,我在尝试将MediaPlayer处理逻辑从MainActivity分离到另一个类时遇到了问题。尽管搜索了很长时间,但仍未找到满意的解决方案。 ... [详细]
  • 我自己做了一个网站图片的抓取,感觉速度有点慢抓取4000张图片可能得用15分钟左右的时间,我百度看用线程可以加快抓取,然后创建了5个线程抓取,但是5个线程是同步执行同样的操作一个图片就 ... [详细]
  • 本文介绍了如何在 Spring Boot 项目中使用 spring-boot-starter-quartz 组件实现定时任务,并将 cron 表达式存储在数据库中,以便动态调整任务执行频率。 ... [详细]
  • 问题描述现在,不管开发一个多大的系统(至少我现在的部门是这样的),都会带一个日志功能;在实际开发过程中 ... [详细]
  • 深入理解:AJAX学习指南
    本文详细探讨了AJAX的基本概念、工作原理及其在现代Web开发中的应用,旨在为初学者提供全面的学习资料。 ... [详细]
  • 在Qt框架中,信号与槽机制是一种独特的组件间通信方式。本文探讨了这一机制相较于传统的C风格回调函数所具有的优势,并分析了其潜在的不足之处。 ... [详细]
  • SDWebImage第三方库学习
    1、基本使用方法异步下载并缓存-(void)sd_setImageWithURL:(nullableNSURL*)urlNS_REFINED_FOR_SWIFT;使用占位图片& ... [详细]
  • Spring Boot + RabbitMQ 消息确认机制详解
    本文详细介绍如何在 Spring Boot 项目中使用 RabbitMQ 的消息确认机制,包括消息发送确认和消息接收确认,帮助开发者解决在实际操作中可能遇到的问题。 ... [详细]
  • 在iOS开发中,多线程技术的应用非常广泛,能够高效地执行多个调度任务。本文将重点介绍GCD(Grand Central Dispatch)在多线程开发中的应用,包括其函数和队列的实现细节。 ... [详细]
  • 优先队列是一种特殊的队列,不遵循先进先出原则。它分为最大优先队列和最小优先队列。最大优先队列总是将当前最大的元素优先出队,而最小优先队列则总是将当前最小的元素优先出队。本文将详细介绍如何使用二叉堆在C#中实现这两种优先队列。 ... [详细]
author-avatar
曾的曾的力
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有