本篇文章为大家展示了Java中怎么实现双保险线程，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。
成都创新互联主要从事成都做网站、成都网站建设、网页设计、企业做网站、公司建网站等业务。立足成都服务涿州,十年网站建设经验,价格优惠、服务专业,欢迎来电咨询建站服务:18982081108
双保险线程，每次启动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个相同的线程，互相检测，避免线程死锁造成影响。 *
* 两个线程都运行，但只有一个线程执行业务，但都会检测对方的时间戳 如果时间戳超过休眠时间3倍没有更新的话，则重新启动对方线程 *
* 代码例子： * 一般工作线程由自己实现，继承DoubleInsuredThead，在run2()方法里实现具体需求，和一般线程的run()方法不同，run2() * 里不用处理循环和休眠 检测线程已经由CheckThread实现，可以直接使用 * *
* 启动用户检测线程 * public static void startMonitor() { * System.out.println("启动用户会话检测线程"); * UserMonitor worker = new UserMonitor("XX-UserMonitor"); * CheckThread checker = new CheckThread("XX-UserMonitorCheck",userMonitorIntevalTime); * DoubleInsuredThead.startDoubleInsuredThead(worker, checker); * } * * * @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); }}
上述内容就是Java中怎么实现双保险线程，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注创新互联行业资讯频道。
