20240427-线程基础-结束线程

线程基础-结束线程

1.stop()方法

2.使用共享变量

package com.ysf.day0427;public class Tst03ShareVar {static volatile boolean flag = true;public static void main(String[] args) throws InterruptedException {Thread t = new Thread(()->{while (flag){//处理业务}System.out.println("任务结束");},"share-1");t.start();Thread.sleep(1000L);flag = false;}
}

3.使用interrupt

3.1 interrupt标记位

线程中存在一个标记位interrupt，来标识线程是否被打断
该标记位默认情况下是false

3.2 查询线程标记位

对象方法：isInterrupted()

package com.ysf.day0427;public class Tst04QueryInterrupt {public static void main(String[] args) throws InterruptedException {Thread t1 = new Thread(()->{for (int i = 0;i<5;i++){System.out.println(i);try {Thread.sleep(500L);} catch (InterruptedException e) {e.printStackTrace();}}},"interrupt-1");t1.start();Thread.sleep(1000L);System.out.println(t1.isInterrupted());}
}

3.3设置线程interrupt标记位为true

对象方法：interrupt()
作用：
- 改变标记位为true
- 打断线程的WAITING或者TIMED_WAITING状态
用法：
- 当用作设置线程结束的方法时（没有sleep，没有wait），标记位会有明显改变
- 当作为打断线程WAITING或者TIMED_WAITING状态的方法时，线程的标记位是不会被改变的

package com.ysf.day0427;import java.util.Date;public class Tst05SetInterrupt {public static void main(String[] args) throws InterruptedException {Thread t1 = new Thread(()->{int count = 0;while (!Thread.currentThread().isInterrupted()){System.out.println("业务处理" + count);count++;// 这里用于证明，在调用了interrupt()方法后，并没有改变线程的标记位System.out.println(Thread.currentThread().isInterrupted());try {System.out.println("开始睡眠");// 睡眠50秒，方便被main线程打断，可以清晰的看出线程并没有睡足50秒Thread.sleep(50000L);} catch (InterruptedException e) {// 当捕获到这个异常的时候会有两种情况// 情况1：我只想打断沉睡// 情况2：我想退出线程if (count<20){// 模拟情况1，如果count小于20的话，那我只想打断沉睡continue;}else {// 模拟情况2，如果count不小于20的话，那我想退出线程// 这里我们不用break或return，我们使用改变标记位的方式// 为什么这里还要再打断一次，因为main线程的打断只是改变了线程WAITING状态，并没有改变标记位Thread.currentThread().interrupt();}}}System.out.println("线程结束");},"interrupt-1");t1.start();// 睡一秒，等待t线程启动Thread.sleep(1000L);for (int i = 0;i<21;i++){Thread.sleep(1000L);t1.interrupt();}}
}

3.3查询线程标记位，并将标记位设置为false

静态方法：Thread.interrupted()
作用：
查询线程的标记位，并且将标记位设置为false

package com.ysf.day0427;public class Tst06SetInterruptFalse {public static void main(String[] args) throws InterruptedException {Thread t1 = new Thread(()->{int count = 0;String name = Thread.currentThread().getName();while (!Thread.currentThread().isInterrupted()){System.out.println(name + "==>" + count);count++;// 这里用于证明，在调用了interrupt()方法后，并没有改变线程的标记位System.out.println(Thread.currentThread().isInterrupted());try {System.out.println(name + "==>" + "开始睡眠");// 睡眠50秒，方便被main线程打断Thread.sleep(50000L);} catch (InterruptedException e) {// 当捕获到这个异常的时候会有两种情况// 情况1：我只想打断沉睡// 情况2：我想退出线程if (count<3){// 模拟情况1，如果count小于3的话，那我只想打断沉睡continue;}else {// 模拟情况2，如果count不小于3的话，那我想退出线程// 这里我们不用break或return，我们使用改变标记位的方式// 为什么这里还要再打断一次，因为main线程的打断只是改变了线程WAITING状态，并没有改变标记位System.out.println(name + "==>" + "count不小于3了");Thread.currentThread().interrupt();// 那如果我在调用了打断之后，我又有其他情况不想退出了呢？// 我们可以在此基础上再调用一次静态方法System.out.println(name + "==>" + Thread.interrupted());}}}System.out.println(name + "==>" + "线程结束");},"interrupt-1");t1.start();// 睡一秒，等待t线程启动Thread.sleep(1000L);for (int i = 0;i<3;i++){String name = Thread.currentThread().getName();Thread.sleep(1000L);System.out.println(name + "==>" + "开始执行第" + i + "次打断");t1.interrupt();}}
}