Java中终止线程的方法详解
Java中终止线程的方式主要有三种:
1、使用stop()方法,已被弃用。原因是:stop()是立即终止,会导致一些数据被到处理一部分就会被终止,而用户并不知道哪些数据被处理,哪些没有被处理,产生了不完整的“残疾”数据,不符合完整性,所以被废弃。So,forgetit!
2、使用volatile标志位
看一个简单的例子:
首先,实现一个Runnable接口,在其中定义volatile标志位,在run()方法中使用标志位控制程序运行
publicclassMyRunnableimplementsRunnable{ //定义退出标志,true会一直执行,false会退出循环 //使用volatile目的是保证可见性,一处修改了标志,处处都要去主存读取新的值,而不是使用缓存 publicvolatilebooleanflag=true; publicvoidrun(){ System.out.println("第"+Thread.currentThread().getName()+"个线程创建"); try{ Thread.sleep(1000L); }catch(InterruptedExceptione){ e.printStackTrace(); } //退出标志生效位置 while(flag){ } System.out.println("第"+Thread.currentThread().getName()+"个线程终止"); } }
然后,在main()方法中创建线程,在合适的时候,修改标志位,终止运行中的线程。
publicclassTreadTest{ publicstaticvoidmain(String[]arg)throwsInterruptedException{ MyRunnablerunnable=newMyRunnable(); //创建3个线程 for(inti=1;i<=3;i++){ Threadthread=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()方法时一定要慎重考虑。
第一种:正在运行中终止
publicclassMyThreadextendsThread{ publicvoidrun(){ super.run(); try{ for(inti=0;i<500000;i++){ if(this.interrupted()){ System.out.println("线程已经终止,for循环不再执行"); thrownewInterruptedException(); } System.out.println("i="+(i+1)); } System.out.println("这是for循环外面的语句,也会被执行"); }catch(InterruptedExceptione){ System.out.println("进入MyThread.java类中的catch了。。。"); e.printStackTrace(); } } }
publicclassRun{ publicstaticvoidmain(Stringargs[]){ Threadthread=newMyThread(); thread.start(); try{ Thread.sleep(2000); thread.interrupt(); }catch(InterruptedExceptione){ e.printStackTrace(); } } }
运行结果如下:
... i=203798 i=203799 i=203800 线程已经终止,for循环不再执行 进入MyThread.java类中的catch了。。。 java.lang.InterruptedException atthread.MyThread.run(MyThread.java:13)
第二种:阻塞状态(sleep,wait等)终止
publicclassMyThreadextendsThread{ publicvoidrun(){ super.run(); try{ System.out.println("线程开始。。。"); Thread.sleep(200000); System.out.println("线程结束。"); }catch(InterruptedExceptione){ System.out.println("在沉睡中被停止,进入catch,调用isInterrupted()方法的结果是:"+this.isInterrupted()); e.printStackTrace(); } } }
线程开始。。。 在沉睡中被停止,进入catch,调用isInterrupted()方法的结果是:false java.lang.InterruptedException:sleepinterrupted atjava.lang.Thread.sleep(NativeMethod) atthread.MyThread.run(MyThread.java:12)
从打印的结果来看,如果在sleep状态下停止某一线程,会进入catch语句,并且清除停止状态值,使之变为false。
前一个实验是先sleep然后再用interrupt()停止,与之相反的操作在学习过程中也要注意:
publicclassMyThreadextendsThread{ publicvoidrun(){ super.run(); try{ System.out.println("线程开始。。。"); for(inti=0;i<10000;i++){ System.out.println("i="+i); } Thread.sleep(200000); System.out.println("线程结束。"); }catch(InterruptedExceptione){ System.out.println("先停止,再遇到sleep,进入catch异常"); e.printStackTrace(); } } } publicclassRun{ publicstaticvoidmain(Stringargs[]){ Threadthread=newMyThread(); thread.start(); thread.interrupt(); } }
运行结果:
i=9998 i=9999 先停止,再遇到sleep,进入catch异常 java.lang.InterruptedException:sleepinterrupted atjava.lang.Thread.sleep(NativeMethod) atthread.MyThread.run(MyThread.java:15)
感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!