使用jstack结合代码来演示【Java线程状态】

简介: Java线程状态一直是让工程师容易迷惑的知识点,我觉得原因有二:一是线程的概念较为抽象,其状态转换的条件和时间点不容易理解;二是线程状态和进程状态不是完全对应的,且线程的状态词汇容易让人误解。下面我们通过jstack结合代码来探究一下Java线程状态相关的关键知识点。

Java线程状态一直是让工程师容易迷惑的知识点,我觉得原因有二:一是线程的概念较为抽象,其状态转换的条件和时间点不容易理解;二是线程状态和进程状态不是完全对应的,且线程的状态词汇容易让人误解。下面我们通过jstack结合代码来探究一下Java线程状态相关的关键知识点。


Java线程状态有哪些?


Java线程底层进程状态并不是完全对应的,它只是JVM暴露给开发者用于了解线程运行情况的状态数据,该状态数据不能用于业务场景的判断。从Thread.State代码中可以看到,Java提供了6种线程状态,如下:



其中比较重要的是RUNNABLE、BLOCKED、WAITING、TIMED_WAITING这几个状态,下面我们分别做简要介绍。


RUNNABLE状态


该状态下的线程处于正在执行的状态,或者可能正在等待来自操作系统(如处理器)的其他资源,对应到操作系统线程中的Running和Ready状态。

比如我们执行一段空代码或者计算代码,此时线程的状态即是RUNNABLE。一般来说,为了能在分析的时候看的更清晰,我们会给线程/线程池定义个名字。



newThread(()->{
while(true){
inti=0;
i++;
i--;
    }
},"busyThread").start();


JDK中自带jstack命令,可以查看线程栈的情况,命令:


jstack -l 进程ID



我们看到,线程状态还有BLOCKED、WAITTING这几种,那么是不是对于I/O阻塞就是这两种呢?我们可以用下面代码测试下:


newThread(()->{
ServerSocketserverSocket=null;
try {
serverSocket=newServerSocket(10086);
while (true) {
//等待接收System.out.println("等待接收...");
Socketsocket=serverSocket.accept();
                }
            } catch (IOExceptione) {
e.printStackTrace();
            } finally {
try {
if(serverSocket!=null){
serverSocket.close();
                    }
                } catch (IOExceptione) {
e.printStackTrace();
                }
            }
        },"socketWaitThread").start();



使用jstack查看,如下图:



会发现,此时仍然是RUNNABLE状态(但CPU占用几乎为0),而不是BLOCKED、WAITTING。


BLOCKED状态


根据前面的例子也可以看出,Blocked状态跟IO阻塞是不一样的。BLOCKED是指线程阻塞时的状态,即等待一个锁的状态。简单来说,大致有两种情况可以让线程处于这个状态。

  1. 线程A想进入某个同步快,但是由于该同步锁被其他线程占用,所以自己只能等待该锁,此时线程A为BLOCKED状态。
  2. 线程A已经获取该锁,进入同步块,但调用了wait方法后释放了该锁,然后其他线程内执行了同一把锁对象的notify或者notifyAll后,此时线程A为BLOCKED状态。

下面代码演示了第一种情况:


Orderobj=newOrder(12);
newThread(()->{
synchronized (obj){
System.out.println("get lock by busyThread");
//等待100秒CommonUtils.waitFor(100000);
            }
        },"busyThread").start();
newThread(()->{
synchronized (obj){
System.out.println("get lock by computeThread");
            }
        },"computeThread").start();



使用jstack可以看到:



busyThread里面执行了一个耗时的操作(100s),导致锁迟迟不释放,computeThread拿不到锁,一直在同步块(synchronized)外等待,此时它就是BLOCKED状态。另外可以清楚的看到,等待锁对象0x00000007ff7b7310,和前面busyThread中locked的是同一个。


WAITING

根据JavaDoc,这个状态的线程会等待另一个线程执行一个特别的操作。让线程处于这个状态,是因为调用了下面的几个方法之一:

没有timeout的Object.wait

没有timeout的Thread.join

LockSupport.park

调用Object.wait时,该状态的线程在等待另一个线程调用Object.notify()或者notifyAll。

调用Thread.join时,该状态的线程在等待一个指定的线程终止操作。


wait/notify

首先我们看看wait/notify这个组合,它主要用于线程间的协作。比如在生产者消费者模式里,当生产者生产的物品达到一定量,消费者消费速度跟不上,此时可能会让生产者wait一下,等消费速度跟上来之后,通过notify来通知生产者继续生产。


调用wait/notify的前提是已经获取对象锁(在synchronized代码块内),而且共用同个对象,下面简单演示下wait/notify的用法:


Orderorder=newOrder(12);
newThread(()->{
synchronized (order){
try {
System.out.println(Thread.currentThread().getName()+" 等待前...");
order.wait();
System.out.println(Thread.currentThread().getName()+" 等待后...");
                } catch (InterruptedExceptione) {
e.printStackTrace();
                }
            }
        },"waitThread").start();
newThread(()->{
synchronized (order){
System.out.println("通知准备...");
CommonUtils.waitFor(60000);
order.notifyAll();
System.out.println("通知完成...");
            }
        },"notifyThread").start();


启动后,用jstack -l打印,结果如下:



程序运行结束后,可以看到控制台打印:



大家会看到,waitThread在调用了wait方法后,在等待notifyThread的notify的过程中,是处于WAITTING状态。它等待的是0x00000007ff7b8878这个对象锁内的notify调用。后者调用后,前者会继续执行完成。


另外,大家可以看到notifyThread由于调用了Thread.sleep方法,它目前处于TIMED_WAITING状态,这个状态后续会再提到。


join


假如有两个线程A和B,A中调用了B的join方法,表示B线程先执行完,才会继续执行A接下来的代码。通过join源码可以看出,之所以能暂停等待其他线程执行,是因为内部也依赖了wait方法,如下图所示:



TIMED_WAITING


这个状态和WAITING很类似,但是它是一种限时的等待。根据JavaDoc可知,在线程中调用下列其中一个方法,可以成为TIME_WAITING状态:

Thread.sleep

有timeout参数的Object.wait

有timeout参数的Thread.join

LockSupport.parkNanos

LockSupport.parkUntil

Thread.sleep的效果在前面有一定展示,这里不再赘述。

目录
相关文章
|
23小时前
|
Java Spring
Java 效率编码 必备插件 Lombok 让代码更优雅
该内容是一个关于Lombok插件的教程摘要:介绍了Lombok用于减少Java开发中的模板代码,提升效率;讲解了如何在IntelliJ IDEA中安装Lombok插件,以及在pom.xml中添加依赖;并提到了@Data注解能自动生成getter/setter、equals、hashCode和toString方法,@Slf4j注解自动处理日志,@Builder用于构建对象,以及@AllArgsConstructor和@NoArgsConstructor注解生成构造函数。还鼓励探索更多Lombok的注解用法。
|
23小时前
|
Java 关系型数据库 测试技术
Java代码一键生成数据库文档(案例详解)
Screw是一个自动化数据库文档生成工具,能根据数据库表结构快速生成简洁、多格式(HTML、Word、Markdown)的文档,支持MySQL、MariaDB等多数据库。它使用Freemarker模板,允许用户自定义样式。依赖包括HikariCP数据库连接池和对应JDBC驱动。通过在Java代码或Maven插件中配置,可方便生成文档。示例代码展示了如何在测试用例中使用Screw。文档效果依赖于数据库中的表和字段注释。
|
1天前
|
NoSQL Java API
java一行代码实现RESTFul接口
Spring Data REST是构建在Spring Data之上的库,可自动将repository转换为REST服务,支持JPA、MongoDB、Neo4j、GemFire和Cassandra。无需手动创建Service和Controller层。要开始,需配置JPA数据源,创建实体类和Repository接口。快速实现REST接口,只需引入spring-boot-starter-data-rest Maven依赖,并在Repository接口上添加@RepositoryRestResource注解。
|
4天前
|
Java 编译器 开发者
【JAVA】为什么代码会重排序
【JAVA】为什么代码会重排序
|
4天前
|
存储 自然语言处理 Java
【JAVA面试题】什么是代码单元?什么是码点?
【JAVA面试题】什么是代码单元?什么是码点?
|
6天前
|
SQL Java 数据库
java代码中调用dao层查询接口,代码没有返回数据,打印出的sql查出了数据
java代码中调用dao层查询接口,代码没有返回数据,打印出的sql查出了数据
12 1
|
6天前
|
安全 Java 开发者
Java编程:深入探索其原理、特性与实战代码
Java编程:深入探索其原理、特性与实战代码
10 1
|
6天前
|
存储 算法 Java
滚雪球学Java(20):Java泛型与枚举:提升代码灵活性与可读性
【4月更文挑战第9天】🏆本文收录于「滚雪球学Java」专栏,专业攻坚指数级提升,希望能够助你一臂之力,帮你早日登顶实现财富自由🚀;同时,欢迎大家关注&&收藏&&订阅!持续更新中,up!up!up!!
21 1
滚雪球学Java(20):Java泛型与枚举:提升代码灵活性与可读性
|
10天前
|
Java 测试技术 持续交付
云效产品使用常见问题之通过流水线构建的java代码,在docker文件里拿到失败如何解决
云效作为一款全面覆盖研发全生命周期管理的云端效能平台,致力于帮助企业实现高效协同、敏捷研发和持续交付。本合集收集整理了用户在使用云效过程中遇到的常见问题,问题涉及项目创建与管理、需求规划与迭代、代码托管与版本控制、自动化测试、持续集成与发布等方面。
|
13天前
|
NoSQL Java Redis
Java代码实现记录接口调用次数
Java代码实现记录接口调用次数