【Java多线程】停止线程
目录
6. 方法stop()与java,lang.ThreadDeath异常
1. 停止线程的方法
在Java中有以下3种方法可以终止正在进行的线程：
1）使用退出标志，使线程正常退出，也就是当run方法完成后线程终止。
2）使用stop方法强行终止线程，但是不推荐使用这个方法，因为stop和suspend及resume一样，都是作废过期的方法，使用它们可能产生不可预料的结果。
3）使用interrupt方法中断线程。
停止一个线程意味着在线程处理完任务之前停掉正在做的操作，也就是放弃当前的操作。虽然这看起来非常简单，但是必须做好防范措施，以便达到预期的效果。停止一个线程可以使用Thread.stop()方法，但最好不用它。虽然它确实可以停止一个正在运行的线程，但是这个方法是不安全的(unsafe)，而且是已被弃用作废的(deprecated), 在将来的Java版本中，这个方法将不可用或不被支持。
大多数停止一个线程的操作使用Thread.interrupt()方法，尽管方法的名称是“停止，中止”的意思，但这个方法不会终止一个正在运行的线程，还需要加入一个判断才可以完成线程的停止。
2. 判断线程是否是停止状态
Thread.java类提供了两种方法。
1）this.interrupted()：测试当前线程是否已经中断。
测试当前线程是否中断。该方法可以清除线程的中断状态，执行后具有将状态标志置消除为false的功能。换句话说，如果这个方法被连续调用两次，那么第二个调用将返回false（除非当前线程再次中断，在第一个调用已经清除其中断状态之后，在第二个调用之前已经检查过）。
忽略线程中断，因为线程在中断时不存在将被该方法返回false所反映。
// 源代码，声明
public void interrupt();
2）this.isInterrupted()：测试线程是否已经中断。
测试这个线程是否被中断。线程的中断状态不受此方法的影响，但不清除状态标志。
忽略线程中断，因为线程在中断时不存在将被该方法返回false所反映。
// 源代码，声明
public static boolean interrupted();
public boolean isInterrupted();
3. 能停止的线程——异常法
下面是一个例子：
自定义线程：
public class MyThread extends Thread {
@Override
public void run() {
super.run();
for (int i = 0; i < 500000; i++) {
if (this.interrupted()) {
System.out.println("已经是停止状态了!我要退出了!");
break;
}
System.out.println("i=" + (i + 1));
}
System.out.println("我被输出，如果此代码是for又继续运行，线程并未停止！");
}
}
运行代码：
public class Run {
public static void main(String[] args) {
try {
MyThread thread = new MyThread();
thread.start();
Thread.sleep(1000);
thread.interrupt();
} catch (InterruptedException e) {
System.out.println("main catch");
e.printStackTrace();
}
System.out.println("end!");
}
}
上面的示例虽然停止了线程，但如果for语句下面还有语句，还是会继续运行的。
将上述代码改为：
public class MyThread extends Thread {
@Override
public void run() {
super.run();
try {
for (int i = 0; i < 500000; i++) {
if (this.interrupted()) {
System.out.println("已经是停止状态了!我要退出了!");
throw new InterruptedException();
}
System.out.println("i=" + (i + 1));
}
System.out.println("我在for下面");
} catch (InterruptedException e) {
System.out.println("进MyThread.java类run方法种的catch了！");
e.printStackTrace();
}
}
}
输出结果：
4. 在沉睡中停止
如果线程在sleep()状态下停止线程，会是什么效果呢？
下面通过一个示例来说明：
public class MyThread extends Thread {
@Override
public void run() {
super.run();
try {
System.out.println("run begin");
Thread.sleep(200000);
System.out.println("run end");
} catch (InterruptedException e) {
System.out.println("在沉睡中被停止!进入catch!"+this.isInterrupted());
e.printStackTrace();
}
}
}
运行代码：
public class Run {
public static void main(String[] args) {
try {
MyThread thread = new MyThread();
thread.start();
Thread.sleep(200);
thread.interrupt();
} catch (InterruptedException e) {
System.out.println("main catch");
e.printStackTrace();
}
System.out.println("end!");
}
}
执行结果：
从打印结果来看，如果在sleep状态下停止某一线程，会进入catch语句，并且清楚停止状态值，使之变成false。
【注】：如果先将线程停止，然后进入sleep，会发生什么呢？如下示例：
public class MyThread extends Thread {
@Override
public void run() {
super.run();
try {
for(int i=0;i<100000;i++){
System.out.println("i="+(i+1));
}
System.out.println("run begin");
Thread.sleep(200000);
System.out.println("run end");
} catch (InterruptedException e) {
System.out.println("先停止，再遇到了sleep!进入catch!");
e.printStackTrace();
}
}
}
public class Run {
public static void main(String[] args) {
MyThread thread = new MyThread();
thread.start();
thread.interrupt();
System.out.println("end!");
}
}
5. 能停止的线程——暴力停止
使用stop()方法停止线程则是非常暴力的。
public class MyThread extends Thread {
private int i = 0;
@Override
public void run() {
try {
while (true) {
i++;
System.out.println("i=" + i);
Thread.sleep(1000);
}
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
public class Run {
public static void main(String[] args) {
try {
MyThread thread = new MyThread();
thread.start();
Thread.sleep(8000);
thread.stop();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
运行结果：
6. 方法stop()与java,lang.ThreadDeath异常
调用stop()方法时会抛出java.lang.ThreadDeath异常，但在通常的情况下，此异常不需要显示地捕捉。
方法stop()已经被作废，因为如果强制让线程停止则有可能使一些清理性的工作得不到完成。另一个情况就是对锁定的对象进行了”解锁“，导致数据得不到同步的处理，出现数据不一致的问题。
7. 使用return停止线程
将方法interrupt()和return结合使用也能实现停止线程的效果。
public class MyThread extends Thread {
@Override
public void run() {
while (true) {
if (this.isInterrupted()) {
System.out.println("停止了!");
return;
}
System.out.println("timer=" + System.currentTimeMillis());
}
}
}
public class Run {
public static void main(String[] args) throws InterruptedException {
MyThread t=new MyThread();
t.start();
Thread.sleep(1000);
t.interrupt();
}
}
执行结果：
不过还是建议使用"抛异常"的方法来实现线程的停止，因为在catch块中还可以将异常向上抛，使线程停止的事件得以传播。
- 点赞
- 收藏
- 关注作者
评论（0）