文章目录
3种方法停止线程
在Java中有以下3种方法可以终止正在运行的线程：
- 使用退出标志，使线程正常退出，也就是当run方法完成后线程终止。
- 使用stop方法强行终止线程，但是不推荐使用这个方法，因为stop和suspend及resume一样，都是作废过期的方法，使用它们可能产生不可预料的结果。
- 使用interrupt方法中断线程。
判断线程是否是停止状态
在Java的SDK中，Thread.java类里提供了两种方法：
1）this.interrupted()：测试当前线程是否已经中断，执行后具有将状态标志置清除为false的功能。
public static boolean interrupted()
2）this.isInterrupted()：测试线程是否已经中断，但不清除状态标志。
public boolean isInterrupted()
interrupted()
this.interrupted() 方法的解释：测试当前线程是否已经中断，当前线程是指运行this.interrupted() 方法的线程。
测试案例1
public class MyThread4 extends Thread {
@Override
public void run() {
super.run();
for (int i = 0; i < 100000; i++) {
System.out.println("i=" + (i + 1));
}
}
}
public static void main(String[] args) {
try {
MyThread4 myThread4 = new MyThread4();
myThread4.start();
Thread.sleep(1000);
myThread4.interrupt();
System.out.println("是否停止1? " + myThread4.interrupted());
System.out.println("是否停止2? " + myThread4.interrupted());
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("End!");
}
输出如下：
...
i=18442
是否停止1? false
是否停止2? false
End!
...
这里强行用了myThread4对象来调用interrupted()方法。
从控制台打印的结果来看，线程并未停止，这也就证明了interrupted() 方法的解释：测试当前线程是否已经中断。这个“当前线程”是main，它从未中断过，所以打印的结果是两个false。
测试案例2
使main线程产生中断效果
public static void main(String[] args) {
Thread.currentThread().interrupt();
System.out.println("是否停止1?" + Thread.interrupted());
System.out.println("是否停止2?" + Thread.interrupted());
System.out.println("End!");
}
输出：
是否停止1?true
是否停止2?false
End!
从上述的结果来看，方法interrupted()的确判断出当前线程是否是停止状态。按照第一个案例来看，但为什么第2个布尔值是false呢？
查看一下官方帮助文档中对interrupted方法的解释：
测试当前线程是否已经中断。线程的中断状态由该方法清除。换句话说，如果连续两次调用该方法，则第二次调用将返回false（在第一次调用已清除了其中断状态之后，且第二次调用检验完中断状态前，当前线程再次中断的情况除外）。文档已经解释得很详细，interrupted()方法具有清除状态的功能，所以第2次调用interrupted()方法返回的值是false。
isInterrupted()
public static void main(String[] args) {
try {
MyThread4 myThread4 = new MyThread4();
myThread4.start();
Thread.sleep(1000);
myThread4.interrupt();
System.out.println("当前线程 " + Thread.currentThread().getName());
System.out.println("是否停止1? " + myThread4.isInterrupted());
System.out.println("是否停止2? " + myThread4.isInterrupted());
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("End!");
}
输出：
...
是否停止1? true
是否停止2? true
...
从结果中可以看到，方法isInterrupted() 并未清除状态标志，所以打印了两个true。
能停止的线程-异常法
在线程中用for语句来判断一下线程是否是停止状态，如果是停止状态，则后面的代码不再运行即可。
测试案例1：
public class MyThread5 extends Thread {
@Override
public void run() {
super.run();
for (int i = 0; i < 100000; i++) {
if (this.isInterrupted()) {
System.out.println("已经是停止状态了，准备退出");
break;
}
System.out.println("i=" + (i + 1));
}
System.out.println("我依然被打印出来！");
}
}
public static void main(String[] args) {
try {
MyThread5 myThread5 = new MyThread5();
myThread5.start();
Thread.sleep(2000);
myThread5.interrupt();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("End!");
}
输出：
i=36732
已经是停止状态了，准备退出
我依然被打印出来！
End!
从结果可知，虽然停止了线程，但如果for语句下面还有语句，还是会继续运行的。
修改MyThread5的run()方法：
public class MyThread5 extends Thread {
@Override
public void run() {
super.run();
try {
for (int i = 0; i < 100000; i++) {
if (this.isInterrupted()) {
System.out.println("已经是停止状态了，准备退出");
throw new InterruptedException();
}
System.out.println("i=" + (i + 1));
}
System.out.println("我在for下面");
} catch (InterruptedException e) {
System.out.println("因为InterruptecException，进入catch块");
e.printStackTrace();
}
}
}
依然用案例1的main方法调用，输出如下：
...
i=21820
i=21821
已经是停止状态了，准备退出
因为InterruptecException，进入catch块
End!
java.lang.InterruptedException
at org.example.thread.MyThread5.run(MyThread5.java:13)
for 语句下面的输出没有执行。
sleep中停止线程
在睡眠中停止线程
public class InterruptAfterSleep {
public static void main(String[] args) {
try {
MyThread6 myThread6 = new MyThread6();
myThread6.start();
Thread.sleep(2000);
myThread6.interrupt();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("end!");
}
}
class MyThread6 extends Thread {
@Override
public void run() {
super.run();
try {
System.out.println("run begin");
Thread.sleep(20000);
System.out.println("run end");
} catch (InterruptedException e) {
System.out.println("线程在sleep中被停止，进入catch," + this.isInterrupted());
e.printStackTrace();
}
}
}
输出：
run begin
end!
线程在sleep中被停止，进入catch,false
java.lang.InterruptedException: sleep interrupted
at java.lang.Thread.sleep(Native Method)
at org.example.thread.MyThread6.run(InterruptAfterSleep.java:23)
线程在sleep（）状态下停止线程，会进入catch语句，并且清除停止状态值，使之变成false。
在睡眠前停止线程
public class InterruptBeforeSleep {
public static void main(String[] args) {
MyThread7 myThread7 = new MyThread7();
myThread7.start();
myThread7.interrupt();
System.out.println("end!");
}
}
class MyThread7 extends Thread {
@Override
public void run() {
super.run();
try {
for (int i = 0; i < 200000; i++) {
System.out.println("i=" + i);
}
System.out.println("run begin");
Thread.sleep(20000);
System.out.println("run end");
} catch (InterruptedException e) {
System.out.println("线程在sleep前被停止，进入catch," + this.isInterrupted());
e.printStackTrace();
}
}
}
输出：
...
i=199999
run begin
线程在sleep前被停止，进入catch,false
java.lang.InterruptedException: sleep interrupted
at java.lang.Thread.sleep(Native Method)
at org.example.thread.MyThread7.run(InterruptBeforeSleep.java:22)
其他方法
-
使用stop() 方法停止线程则是非常暴力的。
方法stop() 已经被作废，因为如果强制让线程停止则有可能使一些清理性的工作得不到完成。另外一个情况就是对锁定的对象进行了“解锁”，导致数据得不到同步的处理，出现数据不一致的问题。 -
使用return停止线程将方法interrupt（）与return结合使用也能实现停止线程的效果。
不过还是建议使用“抛异常”的方法来实现线程的停止，因为在catch块中还可以将异常向上抛，使线程停止的事件得以传播。
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/155783.html
