packagecom.gzczy.concurrent.thread.interrupted;
importjava.util.concurrent.TimeUnit;
importjava.util.concurrent.atomic.AtomicBoolean;
/*** @Description 停止线程三种方法* @Author chenzhengyu* @Date 2021-03-21 15:22*/publicclassSTWThreadDemo {
privatestaticvolatilebooleanflag=true;
privatestaticAtomicBooleanatomicBoolean=newAtomicBoolean(true);
publicstaticvoidmain(String[] args) throwsException{
Threadt1=newThread(() -> {
//demo1();//demo2();demo3();
        },"t1");
t1.start();
TimeUnit.SECONDS.sleep(5);
newThread(()->{
//flag = false;//atomicBoolean.compareAndSet(true,false);t1.interrupt();
        }).start();
    }
/*** 第一种：使用volatile关键字进行停止*/publicstaticvoiddemo1(){
while (flag){
System.out.println("正在运行");
try {
TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedExceptione) {
e.printStackTrace();
            }
        }
    }
/*** 第二种：通过原子类*/publicstaticvoiddemo2(){
while (atomicBoolean.get()){
System.out.println("正在运行");
try {
TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedExceptione) {
e.printStackTrace();
            }
        }
    }
/*** 第三种：通过interrupt方法进行打断*/publicstaticvoiddemo3(){
while (!Thread.currentThread().isInterrupted()){
System.out.println("正在运行");
        }
    }
}

packagecom.gzczy.concurrent.thread.interrupted;
importjava.util.concurrent.TimeUnit;
/*** @Description 线程中断demo* @Author chenzhengyu* @Date 2021-03-21 15:49*/publicclassInterruptErrorDemo {
publicstaticvoidmain(String[] args) throwsException{
Threadt1=newThread(() -> {
CanNotStop();
        }, "t1");
t1.start();
TimeUnit.SECONDS.sleep(3);
Threadt2=newThread(()->{
t1.interrupt();
        },"t2");
t2.start();
    }
/*** 抛出异常后仍然 无法正常打断*/publicstaticvoidCanNotStop(){
while (!Thread.currentThread().isInterrupted()) {
System.out.println("Running.....");
try {
TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedExceptione) {
e.printStackTrace();
            }
        }
    }
}

Running.....
Running.....
Running.....
java.lang.InterruptedException: sleepinterruptedatjava.lang.Thread.sleep(NativeMethod)
atjava.lang.Thread.sleep(Thread.java:340)
atjava.util.concurrent.TimeUnit.sleep(TimeUnit.java:386)
atcom.gzczy.concurrent.thread.interrupted.InterruptErrorDemo.CanNotStop(InterruptErrorDemo.java:31)
atcom.gzczy.concurrent.thread.interrupted.InterruptErrorDemo.lambda$main$0(InterruptErrorDemo.java:14)
atjava.lang.Thread.run(Thread.java:748)
Running.....
Running.....
Running.....
Running.....

packagecom.gzczy.concurrent.thread.interrupted;
importjava.util.concurrent.TimeUnit;
/*** @Description 线程中断demo* @Author chenzhengyu* @Date 2021-03-21 15:49*/publicclassInterruptErrorDemo {
publicstaticvoidmain(String[] args) throwsException{
Threadt1=newThread(() -> {
CanNotStop();
        }, "t1");
t1.start();
TimeUnit.SECONDS.sleep(3);
Threadt2=newThread(()->{
t1.interrupt();
        },"t2");
t2.start();
    }
/*** 抛出异常后仍然 无法正常打断（原因请点击进入API查看，sleep wait join方法打断会清除打断标识）* 在异常部分需要再次打断 重置标志位*/publicstaticvoidCanNotStop(){
while (!Thread.currentThread().isInterrupted()) {
System.out.println("Running.....");
try {
TimeUnit.SECONDS.sleep(1);
            } catch (InterruptedExceptione) {
//我们在刚刚catch代码块再次打断，复位标志位，使其能够正确的中断线程Thread.currentThread().interrupt();
e.printStackTrace();
            }
        }
    }
}

packagecom.gzczy.concurrent.thread.interrupted;
importlombok.extern.slf4j.Slf4j;
/*** @Description 对比打断方法中间* @Author chenzhengyu* @Date 2021-03-21 16:14*/@Slf4j(topic="c.InterruptCompare")
publicclassInterruptCompare {
publicstaticvoidmain(String[] args) {
log.info("==>"+Thread.interrupted());
log.info("==>"+Thread.interrupted());
log.info("========================");
Thread.currentThread().interrupt();
log.info("========================");
//通过观察结果 我们可以看到这里显示为true 因为刚刚打断了，与此同时会将打断状态清空，下次判断为falselog.info("==>"+Thread.interrupted());
// 此方法并不会重置标识位置，只是单纯的显示一下当前状态log.info("==>"+Thread.currentThread().isInterrupted());
log.info("==>"+Thread.interrupted());
    }
}

16:47:54.803 [main] c.InterruptCompare-==>false16:47:54.806 [main] c.InterruptCompare-==>false16:47:54.806 [main] c.InterruptCompare-========================16:47:54.806 [main] c.InterruptCompare-========================16:47:54.806 [main] c.InterruptCompare-==>true16:47:54.806 [main] c.InterruptCompare-==>false16:47:54.806 [main] c.InterruptCompare-==>false

publicstaticbooleaninterrupted() {
returncurrentThread().isInterrupted(true);
}

publicbooleanisInterrupted() {
returnisInterrupted(false);
    }