Java 中终止线程的方式主要有三种:
1、使用 stop() 方法,已被弃用。原因是:stop() 是立即终止,会导致一些数据被到处理一部分就会被终止,而用户并不知道哪些数据被处理,哪些没有被处理,产生了不完整的 "残疾" 数据,不符合完整性,所以被废弃。So, forget it!
2、使用 volatile 标志位
看一个简单的例子:
首先,实现一个 Runnable 接口,在其中定义 volatile 标志位,在 run() 方法中使用标志位控制程序运行
- public class MyRunnable implements Runnable{
- //定义退出标志,true会一直执行,false会退出循环
- //使用volatile目的是保证可见性,一处修改了标志,处处都要去主存读取新的值,而不是使用缓存
- public volatile booleanflag =true;public void run() {
- System.out.println("第"+ Thread.currentThread().getName() +"个线程创建");try{
- Thread.sleep(1000L);
- }catch(InterruptedException e) {
- e.printStackTrace();
- }//退出标志生效位置
- while(flag) {
- }
- System.out.println("第"+ Thread.currentThread().getName() +"个线程终止");
- }
- }
然后,在 main() 方法中创建线程,在合适的时候,修改标志位,终止运行中的线程。
- public classTreadTest {public static void main(String[] arg) throws InterruptedException {
- MyRunnable runnable =newMyRunnable();//创建3个线程
- for(inti =1; i <=3; i++) {
- Thread thread =newThread(runnable, i +"");
- thread.start();
- }//线程休眠 Thread.sleep(2000L);
- System.out.println("——————————————————————————");//修改退出标志,使线程终止 runnable.flag =false;
- }
- }
最后,运行结果,如下:
- 第1个线程创建
- 第2个线程创建第3个线程创建
- --------------------------第3个线程终止
- 第1个线程终止
- 第2个线程终止
3、使用 interrupt() 中断的方式,注意使用 interrupt() 方法中断正在运行中的线程只会修改中断状态位,可以通过 isInterrupted() 判断。如果使用 interrupt() 方法中断阻塞中的线程,那么就会抛出 InterruptedException 异常,可以通过 catch 捕获异常,然后进行处理后终止线程。有些情况,我们不能判断线程的状态,所以使用 interrupt() 方法时一定要慎重考虑。
第一种:正在运行中终止
- public class MyThread extends Thread{
- public void run(){super.run();try{for(inti=0; i<500000; i++){if(this.interrupted()) {
- System.out.println("线程已经终止, for循环不再执行");throw newInterruptedException();
- }
- System.out.println("i="+(i+1));
- }
- System.out.println("这是for循环外面的语句,也会被执行");
- }catch(InterruptedException e) {
- System.out.println("进入MyThread.java类中的catch了。。。");
- e.printStackTrace();
- }
- }
- }
- public classRun {public static void main(String args[]){
- Thread thread =newMyThread();
- thread.start();try{
- Thread.sleep(2000);
- thread.interrupt();
- }catch(InterruptedException e) {
- e.printStackTrace();
- }
- }
- }
运行结果如下:
- ...i=203798i=203799i=203800线程已经终止,for循环不再执行
- 进入MyThread.java类中的catch了。。。
- java.lang.InterruptedException
- at thread.MyThread.run(MyThread.java:13)
第二种:阻塞状态(sleep,wait 等)终止
- public class MyThread extends Thread{
- public void run(){super.run();try{
- System.out.println("线程开始。。。");
- Thread.sleep(200000);
- System.out.println("线程结束。");
- }catch(InterruptedException e) {
- System.out.println("在沉睡中被停止, 进入catch, 调用isInterrupted()方法的结果是:"+this.isInterrupted());
- e.printStackTrace();
- }
- }
- }
- 线程开始。。。
- 在沉睡中被停止, 进入catch, 调用isInterrupted()方法的结果是:falsejava.lang.InterruptedException: sleep interrupted
- at java.lang.Thread.sleep(NativeMethod)at thread.MyThread.run(MyThread.java:12)
从打印的结果来看, 如果在 sleep 状态下停止某一线程,会进入 catch 语句,并且清除停止状态值,使之变为 false。
前一个实验是先 sleep 然后再用 interrupt() 停止,与之相反的操作在学习过程中也要注意:
- public class MyThread extends Thread{
- public void run(){super.run();try{
- System.out.println("线程开始。。。");for(inti=0; i<10000; i++){
- System.out.println("i="+ i);
- }
- Thread.sleep(200000);
- System.out.println("线程结束。");
- }catch(InterruptedException e) {
- System.out.println("先停止,再遇到sleep,进入catch异常");
- e.printStackTrace();
- }
- }
- }public class Run{
- public static void main(String args[]){
- Thread thread =newMyThread();
- thread.start();
- thread.interrupt();
- }
- }
运行结果:
- i=9998i=9999先停止,再遇到sleep,进入catch异常
- java.lang.InterruptedException: sleep interrupted
- at java.lang.Thread.sleep(NativeMethod)at thread.MyThread.run(MyThread.java:15)
总结
对于线程的终止,个人觉得用得最多也最安全的还是属于第二种使用 volatile 标志位来终止线程,因为第三种的使用受到很多方面的制约,一旦没用好会出各种问题。
来源: http://blog.csdn.net/smile_miracle/article/details/71550548