一、两阶段终止模式说明

• 1.在一个线程t1中优雅地终止另一个线程t2，指终止t2线程前，让t2线程有一个料理后事的机会

二、错误思路

• 1.使用线程对象的stop方法停止线程
• 2.stop方法会真正杀死线程，如果线程锁住了共享资源，杀死该线程后再也没有机会释放锁，其它线程将永远无法获取锁
• 3.使用System.exit(int)方法停止线程
• 4.如果只想停止某个线程，System.exit方法会让整个程序都停止

三、实现思路图

四、实现思路

• 1.while(true)死循环
• 2.判断有没有被打断，如果被打断，料理后事，结束循环
• 3.如果没有被打断，睡眠2秒，睡眠期间没有异常，执行操作，继续循环
• 4.睡眠期间有异常，设置打断标记，抓住异常，并重置打断标记，继续循环，判断被打断了，料理后事，结束循环

五、方法说明

• 1.isInterrupted() 判断是否被打断，不会清除打断标记
• 2.interrupt() 打断线程，如果被打断的线程正在sleep、wait、join会导致被打断的线程抛出InterruptedException异常，并清除打断标记；如果被打断正在运行的线程，则会设置打断标记；park的线程被打断也会设置打断标记
• 3.interrupted() 判断当前线程是否被打断，会清除打断标记

六、interrupt实现

6.1 代码示例

package com.learning.interrupt;import lombok.extern.slf4j.Slf4j;/*** @Description 两阶段终止模式*/
@Slf4j
public class TwoPhaseTermination {// 监控线程private Thread monitorThread;// 启动监控线程public void start(){monitorThread = new Thread(()->{while(true){Thread thread = Thread.currentThread();if(thread.isInterrupted()){log.info("料理后事");break;}try {// 睡眠期间被打断Thread.sleep(1000);// 执行监控操作被打断log.info("执行监控操作");} catch (InterruptedException e) {e.printStackTrace();// 重新设置打断标记 为truethread.interrupt();}}});monitorThread.start();}// 停止监控线程public void stop(){monitorThread.interrupt();}public static void main(String[] args) throws InterruptedException {TwoPhaseTermination twoPhaseTermination = new TwoPhaseTermination();twoPhaseTermination.start();Thread.sleep(3500);twoPhaseTermination.stop();}
}

6.2 示例截图

七、volatile实现

7.1 代码示例

package com.learning.interrupt;import lombok.extern.slf4j.Slf4j;/*** @Author Jun.Wang* @Date 2023/5/25 14:32* @Description 两阶段终止模式 volatile*/
@Slf4j
public class TwoPhaseTermination_Volatile {// 监控线程private Thread monitorThread;private volatile boolean stop;// 启动监控线程public void start(){monitorThread = new Thread(()->{while(true){if(this.stop){log.info("料理后事");break;}try {// 睡眠期间被打断Thread.sleep(1000);// 执行监控操作被打断log.info("执行监控操作");} catch (InterruptedException e) {e.printStackTrace();}}});monitorThread.start();}// 停止监控线程public void stop(){this.stop = true;monitorThread.interrupt();}public static void main(String[] args) throws InterruptedException {TwoPhaseTermination_Volatile twoPhaseTermination = new TwoPhaseTermination_Volatile();twoPhaseTermination.start();Thread.sleep(3500);twoPhaseTermination.stop();}
}

7.2 示例截图