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;
 

public abstract class DoubleInsuredThead extends Thread {
 
  
  public static final long DEFAULT_SLEEP_TIME = 1000;
 
  
  private boolean running = true;
  
  private long timeStamp = System.currentTimeMillis();
  
  DoubleInsuredThead another;
 
  public DoubleInsuredThead(String name) {
    super(name);
  }
 
  
  public abstract void run2();
 
  
  public abstract DoubleInsuredThead newInstance();
 
  
  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();
  }
 
  
  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());
      }
    }
  }
 
  
  public long getSleepTime() {
    return DEFAULT_SLEEP_TIME;
  }
 
  
  private void checkAnother() {
    if (another.isTimeout()) {
      another.restart();
    }
  }
 
  
  private boolean isTimeout() {
    System.out.println("timeStamp = " + getTimeStamp());
    return System.currentTimeMillis() - getTimeStamp() > getSleepTime() * 3;
  }
 
  
  public void setTimeStamp(long timeStamp) {
    this.timeStamp = timeStamp;
  }
 
  
  public long getTimeStamp() {
    return timeStamp;
  }
 
}

检测线程：

package com.yx.demo.thread;
 

public class CheckThread extends DoubleInsuredThead {
 
  
  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;
  }
 
  
  public static void main(String[] args) {
    CheckThread worker = new CheckThread("worker", 3000);
    DoubleInsuredThead.startDoubleInsuredThead(worker);
  }
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持考高分网。