如何关闭一个线程
- 调用stop方法。该方法存在一个问题,JDK官方不推荐使用,该方法在关闭线程时可能不会释放掉monitor的锁,所以建议不要使用该方法结束线程。
- 正常关闭
(2.1)线程正常结束生命周期
线程运行结束,完成自己的使命之后,就会正常退出,如果线程中的任务耗时比较短,或者时间可控,那么放任它正常结束就好。
(2.2)捕获中断信号关闭线程
代码如下:
import java.util.concurrent.TimeUnit;
public class InterruptThreadExit {
public static void main(String[] args) throws InterruptedException {
Thread t = new Thread() {
@Override
public void run() {
System.out.println("I will start work");
while (!isInterrupted()) {
//working
}
System.out.println("I will be exiting.");
}
};
t.start();
TimeUnit.SECONDS.sleep(10);
System.out.println("System will be shutdown");
t.interrupt();
}
}
(2.3)使用volatile开关控制
由于线程的interrup标识很有可能被擦除,或者逻辑单元中不会调用任何可中断方法,所以使用volatile修饰的开关flag关闭线程也是一种常用的做法,代码如下:
import java.util.concurrent.TimeUnit;
public class FlagThreadExit {
static class MyTask extends Thread{
private volatile boolean closed = false;
@Override
public void run() {
System.out.println("I will start work");
while (!closed /*&& !isInterrupted()*/){
//working
}
System.out.println("I will be exiting");
}
public void close(){
this.closed = true;
// this.interrupt();
}
}
public static void main(String[] args) throws InterruptedException {
MyTask myTask = new MyTask();
myTask.start();
TimeUnit.SECONDS.sleep(10);
myTask.close();
}
}
3.异常退出
在一个线程的执行单元中,是不允许抛出checked异常的,不论Thread中的run方法,还是Runnable中的run方法,如果线程在运行过程中不需要捕获checked异常并且判断是否还有运行下去的必要,那么此时可以将checked异常封装成unchecked异常(RuntimeException)抛出进而结束生命周期。