本篇文章讲解当线程执行LockSupport.park之后,线程的状态(包括用户级和内核级)以及如何解除线程的状态.
线程状态
public static void main(String[] args) throws Exception {
Thread parkThread = new Thread(new Runnable() {
@Override
public void run() {
// 执行业务代码
// 执行park操作
LockSupport.park(this);
}
}, "parkThread");
// 启动线程
parkThread.start();
}
上面代码中我们启动一个线程,线程在执行过程,首先假设执行一段业务逻辑代码,然后执行了LockSupport.park(this)
,那么这个时候线程会处于什么状态呢?
编译执行上面的代码,通过jstack
查看
可以看到,线程处于WAITING状态,这里显示的状态是线程在JVM中的线程状态,那么这个线程在操作系统(内核)中的状态又是什么呢?
根据上面的堆栈信息,可以看到操作系统的线程ID=0xde9
先将这个十六进制的0xde9转成十进制3561
接下来,通过ps
命令查看操作系统中本进程的各个线程状态
从图中看到,线程的状态是Sleep
总结
1.当执行LockSupport.park(this)时,线程在JVM中的状态是WAITING,线程在内核中的状态是Sleep.
2.线程处于WAITING/Sleep状态,则失去了CPU控制权,处于等待状态,直到某种条件成立,才可以继续运行.
2.如果调用的是java.util.concurrent.locks.LockSupport#parkNanos(java.lang.Object blocker, long nanos),因为设置了等待时间,所以线程的状态不是WAITING,而是TIMED_WAITING.
解除等待
介绍完线程状态,接下来讲解如何解除线程的WAITING/Sleep状态,让线程可以继续运行呢?
第一种方式
LockSupport.unpark(thread)
比如文章最开始创建的一个名称叫parkThread的线程,它处于WAITING状态,我们可以在其他线程中调用LockSupport.unpark(parkThread)让parkThread这个线程重新运行,从等待状态变成可运行状态.
第二种方式
thread.interrupt()
比如我们要中断parkThread这个线程,我们就可以在其他线程中执行parkThread.interrupt().
LockSupport可以响应中断,但不会抛出InterruptedException异常.
学习过AQS的同学应该都看过下面这张图
没有获取到锁的线程,需要进入到同步队列中,通过park进入等待状态.红色的箭头会让线程从等待状态唤醒,继续尝试获取锁.红色箭头的体现就是调用unpark()或者interrupt(),也就是上面我们所说的两种方式.
