public class Test3 {
    public static void main (String[] args) throws Exception{
        TwoPhaseTermination tgt = new TwoPhaseTermination();
        tgt.start();
        Thread.sleep(3500);
        tgt.stop();

    }
}
class TwoPhaseTermination{
    private Thread moniter;
    // 启动监控线程
    public void start(){
        moniter = new Thread(()->{
            while(true){
                Thread now  = Thread.currentThread();
                if(now.isInterrupted()){
                    System.out.println(now.getName()+"处理后事");
                    break;
                }
                try {
                    Thread.sleep(1000);
                    System.out.println(now.getName()+"执行监控记录");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                    // 重新设置打断标记
                    now.interrupt();;

                }
            }
        },"t1");

        moniter.start();
    }
    //停止监控线程
    public void stop(){
        moniter.interrupt();
    }
}