public class InterruptDemo{
    static volatile boolean isStop = false;
    static AtomicBoolean atomicBoolean = new AtomicBoolean(false);
    public static void m3(){
    Thread t1 = new Thread(() -> {
        while (true) {
            if (Thread.currentThread().isInterrupted()) {
                System.out.println("-----isInterrupted() = true,程序結(jié)束。");
                break;
            }
            System.out.println("------hello Interrupt");
        }
    }, "t1");
    t1.start();
    try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); }
    new Thread(() -> {
        t1.interrupt();//修改t1線程的中斷標(biāo)志位為true
    },"t2").start();
}
    /**
     * 通過(guò)AtomicBoolean
     */
    public static void m2(){
        new Thread(() -> {
            while(true)
            {
                if(atomicBoolean.get())
                {
                    System.out.println("-----atomicBoolean.get() = true,程序結(jié)束。");
                    break;
                }
                System.out.println("------hello atomicBoolean");
            }
        },"t1").start();
        //暫停幾秒鐘線程
        try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); }
        new Thread(() -> {
            atomicBoolean.set(true);
        },"t2").start();
    }
    /**
     * 通過(guò)一個(gè)volatile變量實(shí)現(xiàn)
     */
    public static void m1(){
        new Thread(() -> {
            while(true)
            {
                if(isStop)
                {
                    System.out.println("-----isStop = true,程序結(jié)束。");
                    break;
                }
                System.out.println("------hello isStop");
            }
        },"t1").start();
        //暫停幾秒鐘線程
        try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); }
        new Thread(() -> {
            isStop = true;
        },"t2").start();
    }
}

package com.bilibili.juc.interrupt;
import java.util.concurrent.TimeUnit;
/**
 * @auther zzyy
 * @create 2022-01-20 10:52
 */
public class InterruptDemo3
{
    public static void main(String[] args)
    {
        Thread t1 = new Thread(() -> {
            while (true)
            {
                if(Thread.currentThread().isInterrupted())
                {
                    System.out.println(Thread.currentThread().getName()+"\t " +
                            "中斷標(biāo)志位："+Thread.currentThread().isInterrupted()+" 程序停止");
                    break;
                }
                try {
                    Thread.sleep(200);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();//為什么要在異常處，再調(diào)用一次？？
                    e.printStackTrace();
                }
                System.out.println("-----hello InterruptDemo3");
            }
        }, "t1");
        t1.start();
        //暫停幾秒鐘線程
        try { TimeUnit.SECONDS.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); }
        new Thread(() -> t1.interrupt(),"t2").start();
    }
}
/**
 * 1 中斷標(biāo)志位，默認(rèn)false
 * 2 t2 ----> t1發(fā)出了中斷協(xié)商，t2調(diào)用t1.interrupt()，中斷標(biāo)志位true
 * 3 中斷標(biāo)志位true，正常情況，程序停止，^_^
 * 4 中斷標(biāo)志位true，異常情況， 就是t1過(guò)程中調(diào)用了sleep 、join 、 wait 方法 會(huì)拋出一個(gè) InterruptedException(中斷異常)，
 * 將會(huì)把中斷狀態(tài)將被清除，并且將收到InterruptedException 。中斷標(biāo)志位重新設(shè)置為false 導(dǎo)致無(wú)限循環(huán)
 *
 * 5 所以如果要線程中調(diào)用sleep 、join 、 wait 方法 需要在catch塊中，需要再次給中斷標(biāo)志位設(shè)置為true，2次調(diào)用停止程序才OK
 */