Java多线程之线程状态的迁移详解

一、六种状态

java.lang.Thread 的状态分为以下 6 种,它们以枚举的形式,封装在了Thread类内部:

NEW:表示线程刚刚创建出来,还未启动

RUNNABLE:可运行状态,该状态的线程可以是ready或running,唯一的决定因素是线程调度器

BLOCKED:阻塞,线程正在等待一个monitor锁以便进入一个同步代码块

WAITING:等待,一种挂起等待的状态。一个线程处于waiting是为了等待其他线程执行某个特定的动作。

TIMED_WAITING:定时等待。

TERMINATED:终结,线程执行结束后的状态。

二、状态迁移图

线程迁移图网上有很多,这是我自己参考着绘制的一张。

线程迁移图虽然是背了忘忘了背,反反复复很多遍,但是记忆这张图其实并不困难。首先就是NEW和TERMINATED状态,一个表示刚刚创建,一个表示任务结束。

最重要的是记住WAITING和BLOCKED这两种状态与RUNNABLE相互切换的条件。

BLOCKED状态在Java doc中的描述是“等待一个monitor锁”,monitor对象是与对象实例相关联的一个锁对象,这个锁对象实际上就是 synchronized 的具体实现,一般称之为重量级锁,进入同步代码块的过程,实际上就是获取到 monitor 对象的锁的过程。如果锁被其他线程占用,当前线程就变成了BLOCKED状态,如果得到了锁,就由BLOCKED切换到RUNNABLE状态。

WAITING 是一种挂起状态,处于 waiting 的线程表示它正在等待一个有缘人~ 这个有缘人需要执行特定的动作才能解救 waiting 中的线程。就像孙悟空在五指山下等了五百年,只有玄奘摘下山顶的符咒才能够破土而出。

导致 WAITING 的情况只有三种:

wait()

join()

LockSupport.park()

wait() 方法是 Object 的成员方法,它可以令当前线程针对于某个对象挂起等待,并释放获得的锁资源,只有当其他线程调用这个对象的notify()或 notifyAll() 方法,才能够唤醒等待中的线程。注意,notify()或 notifyAll() 不会释放锁资源。

join() 方法是线程的一个成员方法,“加入一个线程”,这好像合情合理,比如 t1线程在执行的过程中调用了 t2.join(),那么好吧, t1就会由 RUNNABLE 变为 WAITING,因为他要等待 t2 执行完后才会继续执行,说白了,就是方便程序员让线程插队用的:

LockSupport.park()更方便,它是一个静态方法,可以让线程在调用的位置直接WAITING,然后在其他线程中,获取到WAITING中的线程对象,传入LockSupport(thread) 直接恢复运行。

三、线程状态模拟

准备三个线程 monitor 监视线程,主要实时监视 t1线程的状态;

t1 线程模拟各种状态,t2 辅助 t1 模拟各种状态:

public class ThreadState {
    static Object lock = new Object();

    // 模拟 NEW、RUNNABLE、WAITING、TIMED_WAITING、BLOCKED、TERMINATED
    public static void main(String[] args) {
        ThreadState thisObj = new ThreadState();
        Thread t1 = new Thread(() -> {
            try {
                // 先获取 t2 对象
                Thread t2 = getThreadByName("t2");
                // 先执行一套逻辑,推迟同步代码块的调用
                String str = "";
                for (int i = 0; i < 10000; i++) {
                    str += i;
                }
                // 调用同步代码块
                thisObj.doSync();
                // t2准备插队
                t2.join();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }, "t1");
        System.out.println("t1 刚创建:" + t1.getState());

        Thread t2 = new Thread(() -> {
            try {
                // 直接获取同步锁
                thisObj.doSync();
                // 释放锁后在运行一段时间
                TimeUnit.SECONDS.sleep(30);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }, "t2");

        Thread monitor = new Thread(() -> {
            Thread.State t1State = null;
            while (true) {
                if (!t1.getState().equals(t1State)) {
                    t1State = t1.getState();
                    System.out.println("t1 此刻状态:" + t1.getState());
                }
                if (t1State.equals(Thread.State.TERMINATED))
                    break;
            }
        }, "monitor");

        monitor.start();
        t2.start();
        t1.start();
    }

    public synchronized void doSync() {
        try {
            TimeUnit.SECONDS.sleep(1);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        String str = "";
        for (int i = 0; i < 100000; i++) {
            str += i;
        }
    }

    public static Thread getThreadByName(String name) {
        Optional<Thread> first = Thread.getAllStackTraces()
                .keySet()
                .stream()
                .filter(thread -> thread.getName().equals(name))
                .findFirst();
        return first.get();
    }
}

输出:

t1 刚创建:NEW
t1 此刻状态:RUNNABLE
t1 此刻状态:BLOCKED
t1 此刻状态:TIMED_WAITING
t1 此刻状态:TIMED_WAITING
t1 此刻状态:RUNNABLE
t1 此刻状态:WAITING
t1 此刻状态:BLOCKED
t1 此刻状态:TERMINATED

总结

线程状态迁移是非常重要的多线程基础知识,在调试多线程问题的时候,能够发挥很大的作用。

6 种状态不仅要熟记,而且在什么情况下会出现这些状态也要清晰明了。

如果条件允许,可以试着通过不同的方法来模拟线程的六种状态的切换,可以加深对线程生命周期的理解。

到此这篇关于Java多线程之线程状态的迁移详解的文章就介绍到这了,更多相关java线程状态迁移内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

(0)

相关推荐

  • java多线程累加计数的实现方法

    题目 给定count=0:让5个线程并发累加到1000: 思路 创建一个类MyRunnable,实现Runnable(继承Thread类也可) 定义一个公共变量count(初始值为0),5个线程都可以访问到: 创建5个线程并发递增count到1000: 注意 这块注意Thread和Runnable类的区别,Thread类是线程类,可以直接new Thread().start运行.而Runnable类是任务类,需要一个线程来承载任务,通过new Thread(new Runnable()).sta

  • Java多线程之ReentrantReadWriteLock源码解析

    一.介绍 1.1 ReentrantReadWriteLock ReentrantReadWriteLock 是一个读写锁,允许多个读或者一个写线程在执行. 内部的 Sync 继承自 AQS,这个 Sync 包含一个共享读锁 ReadLock 和一个独占写锁 WriteLock. 该锁可以设置公平和非公平,默认非公平. 一个持有写锁的线程可以获取读锁.如果该线程先持有写锁,再持有读锁并释放写锁,称为锁降级. WriteLock支持Condition并且与ReentrantLock语义一致,而Re

  • Java多线程导致CPU占用100%解决及线程池正确关闭方式

    简介 情景:1000万表数据导入内存数据库,按分页大小10000查询,多线程,15条线程跑. 使用了ExecutorService executor = Executors.newFixedThreadPool(15) 本地跑了一段时间后,发现电脑CPU逐渐升高,最后CPU占用100%卡死,内存使用也高达80%. 排查问题 Debug 发现虽然创建了定长15的线程池,但是因为数据量大,在For中循环分页查询的List会持续加入LinkedBlockingQueue() 队列中每一个等待的任务,又

  • java多线程导入excel的方法

    一.首先是依赖 <dependency> <groupId>org.apache.poi</groupId> <artifactId>poi</artifactId> <version>3.17</version> </dependency> <dependency> <groupId>org.apache.poi</groupId> <artifactId>po

  • Java多线程之线程同步

    volatile 先看个例子 class Test { // 定义一个全局变量 private boolean isRun = true; // 从主线程调用发起 public void process() { test(); try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } stop(); } // 启动一个子线程循环读取isRun private void test() {

  • Java进阶必备之多线程编程

    一.图示 二.多线程编程 何为多线程,通俗的讲就是让你的代码同时干好几件事. 而我们的一个代码文件或者一个项目就是一个进程,而如果我们想提高效率,我们可以多开几个文件进行多进程,也可以在进程中创建多线程(多写几个方法),但是多进程比较耗费资源,所以一般推荐多线程,在代码里,让代码做几个文件做的事. 多线程编程可以让我们的代码拥有更高效率. 三.线程的工作过程 犹如上图 使用多线程需要先创建一个或者多个线程 然后让线程调用CPU资源,开始运行 然后运行完毕等待所有线程运行完毕 然后删除资源,结束线

  • 总结java多线程之互斥与同步解决方案

    一.线程互斥与同步 互斥:指的是多个线程不能同时访问共享变量 同步:指的是多个线程按指定的顺序执行操作 在同时有多个线程运行过程中,如何达到互斥和同步呢? 加锁即可 在此使用黑马笔记中room例子来说明锁.(ps: 以前就了解锁,但总会记乱,发现使用形象化记忆后就很清楚) 解决互斥 锁就相当于上图的房子,里面放着会被并发访问的共享变量 此时绿色区域(owner)无线程,此时多个线程想并发访问房子里的共享变量,那么只允许其中一个线程进入房子访问,并把房门锁上. 剩下的没有拿到锁的线程只能在entr

  • JAVA多线程中join()方法的使用方法

    虽然关于讨论线程join()方法的博客已经非常极其特别多了,但是前几天我有一个困惑却没有能够得到详细解释,就是当系统中正在运行多个线程时,join()到底是暂停了哪些线程,大部分博客给的例子看起来都像是t.join()方法会使所有线程都暂停并等待t的执行完毕.当然,这也是因为我对多线程中的各种方法和同步的概念都理解的不是很透彻.通过看别人的分析和自己的实践之后终于想明白了,详细解释一下希望能帮助到和我有相同困惑的同学. 首先给出结论:t.join()方法只会使主线程(或者说调用t.join()的

  • Java实战之多线程模拟站点售票

    一.实验题目 二.分析 哦吼,这次的实验题目是一道非常经典的多线程买票问题.题目要求我们创建5个线程来模拟卖票,当然这其中就包含多线程存在也就是我们要解决的问题,重复卖票和超额卖票.即多个窗口卖出同一张票以及窗口卖出非正数编号的票. 不过这个问题可以先放一下,我们先来创建基础的线程模型,并在主方法中创建五个线程让他们跑起来: 话不多说,上代码. public class Ticket { public static void main(String[] args) { for(int i = 1

  • 如何解决Java多线程死锁问题

    死锁问题 死锁定义 多线程编程中,因为抢占资源造成了线程无限等待的情况,此情况称为死锁. 死锁举例 注意:线程和锁的关系是:一个线程可以拥有多把锁,一个锁只能被一个线程拥有. 当两个线程分别拥有一把各自的锁之后,又尝试去获取对方的锁,这样就会导致死锁情况的发生,具体先看下面代码: /** * 线程死锁问题 */ public class DeadLock { public static void main(String[] args) { //创建两个锁对象 Object lock1 = new

随机推荐