java多线程状态及interrupt()方法

时间:2021-08-11 18:36:57


在java多线程中,线程的状态有 NEW, Runnable, Blocked, Waiting, Timed_Waiting, Terminated. 这是java虚拟机下的线程状态,与操作系统下的线程状态略有不同。线程状态以枚举类型定义在Thread.State中,并且当前线程可以通过getState()方法获取当前线程的状态。Runnable其实可以有两种状态,一种是获得了cpu,这在运行,这里把它表示为Running,另一种在队列中,等待调度。

这些状态之间的转化关系可以通过下面的转化图表示:

java多线程状态及interrupt()方法

有些过程没有写,不然太乱了。

这里重点说一下stop()以及interrupt。

对于stop()方法,直接终止线程,释放线程所获的资源,但是在释放过程中会造成对象状态不一致,从而使程序进入未知的境地,已经很久不推荐使用了。可以通过设定标志位来检测线程终止状态,使线程自动终止。简略实现如下:

boolean stop = false;

public void run(){

        while(!stop){

        }

}

在需要终止线程的地方把stop设置为true即可。


interrupt方法好多初学者会感到困惑,发现一些情况下并不能终止线程。在java API中有对此详细的说明:

如果线程在调用 Object 类的 wait()wait(long)wait(long, int) 方法,或者该类的join()join(long)join(long, int)sleep(long)sleep(long, int) 方法过程中受阻,则其中断状态将被清除,它还将收到一个InterruptedException

如果该线程在可中断的通道上的 I/O 操作中受阻,则该通道将被关闭,该线程的中断状态将被设置并且该线程将收到一个ClosedByInterruptException

因此,可以看出,interrupt之后作用到wait() join() 已经sleep()上。 2014阿里巴巴笔试题的附加题中对这个知识进行了终点考核,其代码如下:

public class TestInterrupt {

/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub

Thread thread1 = new Thread(){
public void run(){
try{
long time = System.currentTimeMillis();
while(System.currentTimeMillis()-time<2000){
}
System.out.println("A1");
}
catch(Exception e)
{
System.out.println("B1");
}
}
};
thread1.start();
thread1.interrupt();

//在线程sleep状态下进行中断
Thread thread2 = new Thread(){
public void run(){
try {
this.sleep(2000);
System.out.println("A2");
} catch (Exception e) {
// TODO Auto-generated catch block
System.out.println("B2");
}
}

};

thread2.start();
thread2.interrupt();

//在线程wait状态下进行中断,其中wait()没有在同步块中
Thread thread3 = new Thread(){
public void run(){
try {
this.wait(2000);
System.out.println("A3");
} catch (Exception e) {
// TODO Auto-generated catch block
System.out.println("B3");
}
}

};

thread3.start();
thread3.interrupt();

//在线程wait状态下进行中断,其中wait()在同步块中
Thread thread4 = new Thread(){
public void run(){
try {
synchronized(this){
this.wait(2000);
System.out.println("A4");}
} catch (Exception e) {
// TODO Auto-generated catch block
System.out.println("B4");
}
}

};

thread4.start();
thread4.interrupt();


try{
thread4.start();
System.out.println("A5");
}
catch(Exception e)
{
System.out.println("B5");
System.out.println(e.toString());
}


}

}

我们可以运行,发下运行结果如下(不考虑执行顺序):

A1

B2

B3

B4

B5