public class TestClassSenseOne {
    public static void main(String[] args) throws InterruptedException {
        TestThread t = new TestThread();
        //開(kāi)啟子線程執(zhí)行
        t.start();
        //中斷子線程
        t.interrupt();
        //等待子線程執(zhí)行完畢,t.join() 可以這么理解，誰(shuí).join() 誰(shuí)阻塞當(dāng)前線程先執(zhí)行自己
        t.join();
        System.out.println("主線程結(jié)束");
    }
}
class TestThread extends Thread {
    @Override
    public void run() {
        while (!Thread.currentThread().isInterrupted()) {
            //沒(méi)有被標(biāo)記為中斷狀態(tài)就執(zhí)行，上面start后直接調(diào)用中斷，這句是不會(huì)輸出的
            System.out.println("我沒(méi)有被中斷");
        }
        System.out.println("啊——————————————————————————————斷了。");
    }
}

public class TestClassSenseTwo {
    public static void main(String[] args) throws InterruptedException {
        TestThreadTwo t = new TestThreadTwo();
        //開(kāi)啟子線程執(zhí)行
        t.start();
        //模擬真實(shí)任務(wù)，其實(shí)執(zhí)行5秒就執(zhí)行完了，再繼續(xù)等待到20s毫無(wú)意義
        Thread.sleep(5000);
        System.out.println("模擬真實(shí)任務(wù)，其實(shí)執(zhí)行5秒就執(zhí)行完了，再繼續(xù)等待到20s毫無(wú)意義");
        //所以在這里中斷子線程
        t.interrupt();
        //等待子線程執(zhí)行完畢,t.join() 可以這么理解，誰(shuí).join() 誰(shuí)阻塞當(dāng)前線程先執(zhí)行自己
        t.join();
        System.out.println("主線程結(jié)束");
    }
}
class TestThreadTwo extends Thread {
    @Override
    public void run() {
        try {
            System.out.println("開(kāi)始執(zhí)行20秒的任務(wù)");
            Thread.sleep(20000);
            System.out.println("線程任務(wù)執(zhí)行完畢");
        } catch (InterruptedException e) {
            System.out.println("線程在sleep的時(shí)候被中斷。");
            return;
        }
    }
}

public interface TestService {
    void checkMenu() throws InterruptedException;
}

public class TestServiceImpl implements TestService {
    @Override
    public void checkMenu() throws InterruptedException {
        System.out.println("檢查菜單----------->");
        //模擬隨機(jī)成功與失敗
        if (Math.random() * 10 > 4) {
            //模擬執(zhí)行檢查任務(wù)需要3秒耗時(shí)
            Thread.sleep(3000);
            //使用中斷的方式，結(jié)束任務(wù)。
            System.out.println("檢查任務(wù)完成******************，checkMenu()  使用interrupt()結(jié)束任務(wù)");
            Thread.currentThread().interrupt();
        }
    }
}

class DoMenuCheckTask extends Thread {
    @Override
    public void run() {
        TestService testService = new TestServiceImpl();
        //如果當(dāng)前線程沒(méi)有被中斷，說(shuō)明 checkMenu 沒(méi)有真正成功
        while (!Thread.currentThread().isInterrupted()) {
            try {
                testService.checkMenu();
                /*
                  下面這兩行的開(kāi)啟與關(guān)閉，便是兩種結(jié)束當(dāng)前任務(wù)的方式
                   1. 這里不使用sleep ，任務(wù)正常被 interrupt 結(jié)束
                   2. 這里使用 sleep， interrupt打斷的就是 sleep()，打斷sleep會(huì)清除isInterrupted中斷狀態(tài)，
                        并拋出 java.lang.InterruptedException: sleep interrupted 異常，所以，不在catch塊中結(jié)束任務(wù)，
                        任務(wù)便無(wú)法結(jié)束了。
                 */
//                System.out.println("菜單檢查沒(méi)有通過(guò)中斷完成任務(wù)，休眠5秒后繼續(xù)執(zhí)行----------");
//                //如果這里使用了 sleep 那么任務(wù)便是通過(guò)下面catch塊中結(jié)束。
//                Thread.sleep(5000);
            } catch (InterruptedException e) {
                //被中斷，任務(wù)結(jié)束
                e.printStackTrace();
                System.out.println("菜單檢查通過(guò)中斷interrupt成功完成----------->>>>>>>>");
                return;
            }
        }
    }
}

public class SceneExample {
    public static void main(String[] args) throws InterruptedException {
        System.out.println("主線程開(kāi)始執(zhí)行----------->>>>>>>>");
        DoMenuCheckTask task = new DoMenuCheckTask();
        //開(kāi)始菜單檢查執(zhí)行任務(wù)
        task.start();
        //讓檢查任務(wù)先執(zhí)行
        task.join();
        System.out.println("主線程結(jié)束執(zhí)行----------->>>>>>>>");
    }
}