当前位置:   article > 正文

Java之线程停止

线程run方法中有死循环,那么线程什么时候关闭
Thread.stop、Thread.suspend、Thread.resume 和Runtime.runFinalizersOnExit 这些终止线程运行的方法已经被废弃,因为它存在安全隐患。

Java线程一般在执行完run方法就可以正常结束,不过有一类线程叫做伺服线程,不间断地执行,往往在run方法中有一个死循环,监视着某些条件,只有当这些条件满足时才能结束。例:
public void run() {       while(true){           someWork();           if(finished){              break;           }           try {              Thread.sleep(10000);           } catch (InterruptedException e) {              e.printStackTrace();           }       }}


我们可以在while死循环内,每次循环时,察看外部条件,看看是否需要关闭当前线程。如果是,就break,跳出死循环,或者是抛出异常,跳出死循环,结束线程。

有些执行伺服任务的线程,在while(true)这样的死循环内部,是一个阻塞中的方法。此时,就不能采用第二种方法了。因为,当该方法没有返回时,该线程一直处于阻塞当中,根本无法执行其他语句。

此时,就需要调用该线程的interrupt方法,产生一个InterruptedException运行时异常,是阻塞中的那个方法抛出这个异常,从而让我们有机会结束这个线程的执行。

这里说一种特殊情况,有些情况可能你需要一下子停止整个系统的所有线程,这样子上面的方法就不是那么高效,思路也差不多。例如下面的Thread1、Thread2。
public class Thread1 extends Thread {	@Override	public void run() {		while(true) {			try {				doSomeWork();				if (finished) {					break;				}				//	wait for some resource				} catch (InterruptedException e) {					// ...					break;				}		}	}}public class Thread2 extends Thread {	@Override	public void run() {		while(true) {			try {				doSomeWork();				if (finished) {					break;				}				//	wait for some resource				} catch (InterruptedException e) {					// ...					break;				}		}	}}


显然,通过上面那两种方法不能一下子停止这些线程,因为我们不能做到这些线程能同时满足条件,此外这些线程也不可能一块堵塞。这里我们通过改变whlie条件来解决这个问题,在我们的Thread1、Thread2上面增加一个父类AbstractThread,例:
public abstract class  AbstractThread extends Thread {   protected AtomicBoolean isRunning = new AtomicBoolean(true);   public void stopRunning() {           isRunning.set(false);   }}


然后使Thread1、Thread2继承AbstractThread,然后修改while循环为如下:
while(isRunning) {      ...}


在停止线程时,调用每个线程的stopRunning方法,如果存在堵塞的情况,在辅助调用该线程的interrupt方法。
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/木道寻08/article/detail/1004285
推荐阅读
相关标签
  

闽ICP备14008679号