在java多线程中,线程的状态有 NEW, Runnable, Blocked, Waiting, Timed_Waiting, Terminated. 这是java虚拟机下的线程状态,与操作系统下的线程状态略有不同。线程状态以枚举类型定义在Thread.State中,并且当前线程可以通过getState()方法获取当前线程的状态。Runnable其实可以有两种状态,一种是获得了cpu,这在运行,这里把它表示为Running,另一种在队列中,等待调度。
这些状态之间的转化关系可以通过下面的转化图表示:
有些过程没有写,不然太乱了。
这里重点说一下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