Java实现双保险线程的示例代码
作者:IT_熊 发布时间:2023-09-21 07:59:46
标签:Java,双保险,线程
双保险线程,每次启动2个相同的线程,互相检测,避免线程死锁造成影响。
两个线程都运行,但只有一个线程执行业务,但都会检测对方的时间戳 如果时间戳超过休眠时间3倍没有更新的话,则重新启动对方线程。
例子:
一般工作线程由自己实现,继承DoubleInsuredThead,在run2()方法里实现具体需求,和一般线程的run()方法不同,run2()里不用处理循环和休眠 检测线程已经由CheckThread实现,可以直接使用,如:启动用户检测线程。
public static void startMonitor() {
System.out.println("启动用户会话检测线程");
UserMonitor worker = new UserMonitor("WT-UserMonitor");
CheckThread checker = new CheckThread("WT-UserMonitorCheck",userMonitorIntevalTime);
DoubleInsuredThead.startDoubleInsuredThead(worker, checker);
}
完整代码:
package com.yx.demo.thread;
/**
* DoubleInsuredThead
* 双保险线程,每次启动2个相同的线程,互相检测,避免线程死锁造成影响。
* <p>
* 两个线程都运行,但只有一个线程执行业务,但都会检测对方的时间戳 如果时间戳超过休眠时间3倍没有更新的话,则重新启动对方线程
* <p>
* 代码例子:
* 一般工作线程由自己实现,继承DoubleInsuredThead,在run2()方法里实现具体需求,和一般线程的run()方法不同,run2()
* 里不用处理循环和休眠 检测线程已经由CheckThread实现,可以直接使用
*
* <pre>
* 启动用户检测线程
* public static void startMonitor() {
* System.out.println("启动用户会话检测线程");
* UserMonitor worker = new UserMonitor("XX-UserMonitor");
* CheckThread checker = new CheckThread("XX-UserMonitorCheck",userMonitorIntevalTime);
* DoubleInsuredThead.startDoubleInsuredThead(worker, checker);
* }
* </pre>
*
* @author yx
* @date 2019/12/21 0:36
*/
public abstract class DoubleInsuredThead extends Thread {
/**
* 默认线程休眠时间为1000毫秒
*/
public static final long DEFAULT_SLEEP_TIME = 1000;
/**
* 是否运行本线程
*/
private boolean running = true;
/**
* 线程时间戳,每次run的时候更新
*/
private long timeStamp = System.currentTimeMillis();
/**
* 互相检测的另外一个线程
*/
DoubleInsuredThead another;
public DoubleInsuredThead(String name) {
super(name);
}
/**
* 子线程的执行业务的方法,相当于Runnable.run()方法
*/
public abstract void run2();
/**
* 获得实例,重启线程的时候用
*
* @return
*/
public abstract DoubleInsuredThead newInstance();
/**
* 启动工作线程,使用默认检测线程
*
* @param workerThread
*/
public static void startDoubleInsuredThead(DoubleInsuredThead workerThread) {
CheckThread checkerThread =
new CheckThread(workerThread.getName() + "-checker", workerThread.getSleepTime());
workerThread.another = checkerThread;
checkerThread.another = workerThread;
workerThread.start();
checkerThread.start();
}
/**
* 自定义检测线程的方式启动工作线程,建议使用startDoubleInsuredThead(DoubleInsuredThead workerThread)
*
* @param worker 工作线程
* @param checker 检测线程
* @deprecated
*/
public static void startDoubleInsuredThead(DoubleInsuredThead worker,
DoubleInsuredThead checker) {
worker.another = checker;
checker.another = worker;
worker.start();
checker.start();
}
/**
* 重启线程
*/
public void restart() {
System.out.println("线程\"" + getName() + "\"重新启动了");
// 停止当前线程
running = false;
// 启动新线程
DoubleInsuredThead t = newInstance();
t.setTimeStamp(System.currentTimeMillis());
another.another = t;
t.another = another;
t.start();
}
@Override
public void run() {
while (running) {
// 执行子类线程的业务
run2();
checkAnother();
setTimeStamp(System.currentTimeMillis());
try {
Thread.sleep(getSleepTime());
} catch (InterruptedException e) {
e.printStackTrace();
System.out.println("线程休眠出错:" + e.getMessage());
}
}
}
/**
* 获得线程休眠的时间,单位毫秒
*
* @return
*/
public long getSleepTime() {
return DEFAULT_SLEEP_TIME;
}
/**
* 对另外一个线程进行检测
*/
private void checkAnother() {
if (another.isTimeout()) {
another.restart();
}
}
/**
* 是否更新时间戳超时
*
* @return
*/
private boolean isTimeout() {
System.out.println("timeStamp = " + getTimeStamp());
return System.currentTimeMillis() - getTimeStamp() > getSleepTime() * 3;
}
/**
* @param timeStamp the timeStamp to set
*/
public void setTimeStamp(long timeStamp) {
this.timeStamp = timeStamp;
}
/**
* @return the timeStamp
*/
public long getTimeStamp() {
return timeStamp;
}
}
检测线程:
package com.yx.demo.thread;
/**
* CheckThread
* 双保险线程里专门用来检测的线程
*
* @author yx
* @date 2019/12/21 0:38
*/
public class CheckThread extends DoubleInsuredThead {
/**
* 检测休眠时间,默认1秒
*/
private long checkIntevalTime = 1000;
public CheckThread(String name, long checkTime) {
super(name);
this.checkIntevalTime = checkTime;
}
@Override
public DoubleInsuredThead newInstance() {
return new CheckThread(getName(), checkIntevalTime);
}
@Override
public void run2() {
// 只打印信息
System.out.println("线程" + getName() + "完成了工作");
}
@Override
public long getSleepTime() {
return checkIntevalTime;
}
/**
* 测试代码
*
* @param args
*/
public static void main(String[] args) {
CheckThread worker = new CheckThread("worker", 3000);
DoubleInsuredThead.startDoubleInsuredThead(worker);
}
}
来源:https://blog.csdn.net/servermanage/article/details/103640228
0
投稿
猜你喜欢
- 一、前言(吐槽+煽情+简介) &n
- 1、右值1.1 简介首先区分一下左右值:左值是指存储在内存中、有明确存储地址(可取地址)的数据;右值是指可以提供数据值的数据(不可取地址)如
- IDEA快速搭建spring boot项目1.创建项目老规矩,点击Create New Project2.编写控制器在com.demo.sp
- Java基于对象流实现银行系统的具体代码,供大家参考,具体内容如下系统特点:数据持久化到文件中,系统启动后,加载文件中数据到集合中,相当于做
- File类概述File类能新建、删除、重命名文件和目录,但不能访问文件内容本身,如果需要访问文件内容本身,则需要使用后续的输入/输出流。要在
- 本篇给大家详细讲解了MTKAndroid平台开发流程,大致分为44个步骤,我们把每个步骤的命令详细讲解了下,一起来学习下。1.拷贝代码仓库从
- 本文介绍了Spring Boot Admin监控服务上下线邮件通知,分享给大家,具体如下:微服务架构下,服务的数量少则几十,多则上百,对服务
- 先看下效果:两种需求场景:1.广告页3s后跳转到首页2.短信验证码60s倒计时第一种的话,根据需求我们可以知道,我们想要的效果就是3s结束做
- 首先引入pom <!--SpringBoot 2.1.0--> <parent>  
- jpa EntityManager复杂查询概念EntityManager:EntityManager是JPA中用于增删改查的接口,它的作用相
- 更新了AS 3.1.2之后,发现新建Kotlin类,类注释依然木有,没办法只有自己动手了。方法很简单,编辑File Header就可以啦。只
- 最近有小伙伴问我,双枚举类该怎么写,还得包括根据key取值方法。于是就手写一个案例如下:/** * 关系类型枚举 */public enum
- [LeetCode] 205. Isomorphic Strings 同构字符串Given two strings s
- 在 fluro 中,定义路由处理器 Handler 时可以指定该页面的默认转场形式,或者在使用 navigateTo 方法是可以设置页面跳转
- 先上图下拉刷新跟原生开发一样,下拉刷新在flutter里提供的有组件实现 RefreshIndicator一直不明白为啥组件中都提供下拉刷新
- 合并有序数组的实现java版本:实例代码public class Merge {//合并有序数组 public static v
- java遍历json字符串,取得相应KV值时,各种麻烦,比如将json中的list取出来转为JSONArray,再将list中的object
- 代码入下:import java.io.*; public class Practice { publ
- 项目中肯定会遇到异步调用其他方法的场景,比如有个计算过程,需要计算很多个指标的值,但是每个指标计算的效率快慢不同,如果采用同步执行的方式,运
- springboot嵌套子类使用在实际项目里,我们会使用到一个User用户含有子类Address、这种嵌套子类在开发中会遇到很多问题,现在主