public static void startMonitor() {
 System.out.println("啟動(dòng)用戶會(huì)話檢測(cè)線程");
 UserMonitor worker = new UserMonitor("WT-UserMonitor");
 CheckThread checker = new CheckThread("WT-UserMonitorCheck",userMonitorIntevalTime);
 DoubleInsuredThead.startDoubleInsuredThead(worker, checker);
}

package com.yx.demo.thread;
 
/**
 * DoubleInsuredThead
 * 雙保險(xiǎn)線程，每次啟動(dòng)2個(gè)相同的線程，互相檢測(cè)，避免線程死鎖造成影響。
 * <p>
 * 兩個(gè)線程都運(yùn)行，但只有一個(gè)線程執(zhí)行業(yè)務(wù)，但都會(huì)檢測(cè)對(duì)方的時(shí)間戳 如果時(shí)間戳超過(guò)休眠時(shí)間3倍沒(méi)有更新的話，則重新啟動(dòng)對(duì)方線程
 * <p>
 * 代碼例子：
 * 一般工作線程由自己實(shí)現(xiàn)，繼承DoubleInsuredThead，在run2()方法里實(shí)現(xiàn)具體需求，和一般線程的run()方法不同，run2()
 * 里不用處理循環(huán)和休眠 檢測(cè)線程已經(jīng)由CheckThread實(shí)現(xiàn)，可以直接使用
 *
 * <pre>
 *  啟動(dòng)用戶檢測(cè)線程
 *  public static void startMonitor() {
 *  System.out.println("啟動(dòng)用戶會(huì)話檢測(cè)線程");
 *  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 {
 
  /**
   * 默認(rèn)線程休眠時(shí)間為1000毫秒
   */
  public static final long DEFAULT_SLEEP_TIME = 1000;
 
  /**
   * 是否運(yùn)行本線程
   */
  private boolean running = true;
  /**
   * 線程時(shí)間戳，每次run的時(shí)候更新
   */
  private long timeStamp = System.currentTimeMillis();
  /**
   * 互相檢測(cè)的另外一個(gè)線程
   */
  DoubleInsuredThead another;
 
  public DoubleInsuredThead(String name) {
    super(name);
  }
 
  /**
   * 子線程的執(zhí)行業(yè)務(wù)的方法，相當(dāng)于Runnable.run()方法
   */
  public abstract void run2();
 
  /**
   * 獲得實(shí)例，重啟線程的時(shí)候用
   *
   * @return
   */
  public abstract DoubleInsuredThead newInstance();
 
  /**
   * 啟動(dòng)工作線程，使用默認(rèn)檢測(cè)線程
   *
   * @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();
  }
 
  /**
   * 自定義檢測(cè)線程的方式啟動(dòng)工作線程，建議使用startDoubleInsuredThead(DoubleInsuredThead workerThread)
   *
   * @param worker 工作線程
   * @param checker 檢測(cè)線程
   * @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() + "\"重新啟動(dòng)了");
    // 停止當(dāng)前線程
    running = false;
    // 啟動(dòng)新線程
    DoubleInsuredThead t = newInstance();
    t.setTimeStamp(System.currentTimeMillis());
    another.another = t;
    t.another = another;
    t.start();
  }
 
  @Override
  public void run() {
    while (running) {
      // 執(zhí)行子類(lèi)線程的業(yè)務(wù)
      run2();
      checkAnother();
      setTimeStamp(System.currentTimeMillis());
 
      try {
        Thread.sleep(getSleepTime());
      } catch (InterruptedException e) {
        e.printStackTrace();
        System.out.println("線程休眠出錯(cuò)：" + e.getMessage());
      }
    }
  }
 
  /**
   * 獲得線程休眠的時(shí)間，單位毫秒
   *
   * @return
   */
  public long getSleepTime() {
    return DEFAULT_SLEEP_TIME;
  }
 
  /**
   * 對(duì)另外一個(gè)線程進(jìn)行檢測(cè)
   */
  private void checkAnother() {
    if (another.isTimeout()) {
      another.restart();
    }
  }
 
  /**
   * 是否更新時(shí)間戳超時(shí)
   *
   * @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
 * 雙保險(xiǎn)線程里專(zhuān)門(mén)用來(lái)檢測(cè)的線程
 *
 * @author yx
 * @date 2019/12/21 0:38
 */
public class CheckThread extends DoubleInsuredThead {
 
  /**
   * 檢測(cè)休眠時(shí)間，默認(rèn)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;
  }
 
  /**
   * 測(cè)試代碼
   *
   * @param args
   */
  public static void main(String[] args) {
    CheckThread worker = new CheckThread("worker", 3000);
    DoubleInsuredThead.startDoubleInsuredThead(worker);
  }
}