使用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的效果在前面有一定展示,这里不再赘述。

目录
相关文章
|
16天前
|
Java
在 Java 中捕获和处理自定义异常的代码示例
本文提供了一个 Java 代码示例,展示了如何捕获和处理自定义异常。通过创建自定义异常类并使用 try-catch 语句,可以更灵活地处理程序中的错误情况。
|
6天前
|
供应链 安全 NoSQL
PHP 互斥锁:如何确保代码的线程安全?
在多线程和高并发环境中,确保代码段互斥执行至关重要。本文介绍了 PHP 互斥锁库 `wise-locksmith`,它提供多种锁机制(如文件锁、分布式锁等),有效解决线程安全问题,特别适用于电商平台库存管理等场景。通过 Composer 安装后,开发者可以利用该库确保在高并发下数据的一致性和安全性。
24 6
|
1月前
|
XML 安全 Java
Java反射机制:解锁代码的无限可能
Java 反射(Reflection)是Java 的特征之一,它允许程序在运行时动态地访问和操作类的信息,包括类的属性、方法和构造函数。 反射机制能够使程序具备更大的灵活性和扩展性
40 5
Java反射机制:解锁代码的无限可能
|
1天前
|
安全 Java API
Java中的Lambda表达式:简化代码的现代魔法
在Java 8的发布中,Lambda表达式的引入无疑是一场编程范式的革命。它不仅让代码变得更加简洁,还使得函数式编程在Java中成为可能。本文将深入探讨Lambda表达式如何改变我们编写和维护Java代码的方式,以及它是如何提升我们编码效率的。
|
26天前
|
jenkins Java 测试技术
如何使用 Jenkins 自动发布 Java 代码,通过一个电商公司后端服务的实际案例详细说明
本文介绍了如何使用 Jenkins 自动发布 Java 代码,通过一个电商公司后端服务的实际案例,详细说明了从 Jenkins 安装配置到自动构建、测试和部署的全流程。文中还提供了一个 Jenkinsfile 示例,并分享了实践经验,强调了版本控制、自动化测试等关键点的重要性。
60 3
|
1月前
|
存储 安全 Java
系统安全架构的深度解析与实践:Java代码实现
【11月更文挑战第1天】系统安全架构是保护信息系统免受各种威胁和攻击的关键。作为系统架构师,设计一套完善的系统安全架构不仅需要对各种安全威胁有深入理解,还需要熟练掌握各种安全技术和工具。
91 10
|
27天前
|
分布式计算 Java MaxCompute
ODPS MR节点跑graph连通分量计算代码报错java heap space如何解决
任务启动命令:jar -resources odps-graph-connect-family-2.0-SNAPSHOT.jar -classpath ./odps-graph-connect-family-2.0-SNAPSHOT.jar ConnectFamily 若是设置参数该如何设置
|
26天前
|
Java
Java代码解释++i和i++的五个主要区别
本文介绍了前缀递增(++i)和后缀递增(i++)的区别。两者在独立语句中无差异,但在赋值表达式中,i++ 返回原值,++i 返回新值;在复杂表达式中计算顺序不同;在循环中虽结果相同但使用方式有别。最后通过 `Counter` 类模拟了两者的内部实现原理。
Java代码解释++i和i++的五个主要区别
|
2月前
|
搜索推荐 Java 数据库连接
Java|在 IDEA 里自动生成 MyBatis 模板代码
基于 MyBatis 开发的项目,新增数据库表以后,总是需要编写对应的 Entity、Mapper 和 Service 等等 Class 的代码,这些都是重复的工作,我们可以想一些办法来自动生成这些代码。
33 6
|
2月前
|
Java
通过Java代码解释成员变量(实例变量)和局部变量的区别
本文通过一个Java示例,详细解释了成员变量(实例变量)和局部变量的区别。成员变量属于类的一部分,每个对象有独立的副本;局部变量则在方法或代码块内部声明,作用范围仅限于此。示例代码展示了如何在类中声明和使用这两种变量。