线程的6种状态(juc编程)

嚴華  金牌会员 | 2024-6-20 21:19:34 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题

主题 916|帖子 916|积分 2748

1 线程状态

1.1 状态介绍

当线程被创建并启动以后,它既不是一启动就进入了实行状态,也不是一直处于实行状态。线程对象在差别的时期有差别的状态。那么Java中的线程存在哪几种状态呢?Java中的线程
状态被定义在了java.lang.Thread.State枚举类中,State枚举类的源码如下:
  1. public class Thread {
  2.    
  3.     public enum State {
  4.    
  5.         /* 新建 */
  6.         NEW ,
  7.         /* 可运行状态 */
  8.         RUNNABLE ,
  9.         /* 阻塞状态 */
  10.         BLOCKED ,
  11.         /* 无限等待状态 */
  12.         WAITING ,
  13.         /* 计时等待 */
  14.         TIMED_WAITING ,
  15.         /* 终止 */
  16.         TERMINATED;
  17.    
  18.         }
  19.    
  20.     // 获取当前线程的状态
  21.     public State getState() {
  22.         return jdk.internal.misc.VM.toThreadState(threadStatus);
  23.     }
  24.    
  25. }
复制代码
通过源码我们可以看到Java中的线程存在6种状态,每种线程状态的含义如下
线程状态详细含义NEW一个尚未启动的线程的状态。也称之为初始状态、开始状态。线程刚被创建,但是并未启动。还没调用start方法。MyThread t = new MyThread()只有线程象,没有线程特征。RUNNABLE当我们调用线程对象的start方法,那么此时线程对象进入了RUNNABLE状态。那么此时才是真正的在JVM历程中创建了一个线程,线程一经启动并不是立即得到实行,线程的运行与否要听令与CPU的调度,那么我们把这个中央状态称之为可实行状态(RUNNABLE)也就是说它具备实行的资格,但是并没有真正的实行起来而是在等待CPU的度。BLOCKED当一个线程试图获取一个对象锁,而该对象锁被其他的线程持有,则该线程进入Blocked状态;当该线程持有锁时,该线程将变成Runnable状态。WAITING一个正在等待的线程的状态。也称之为等待状态。造成线程等待的原因有两种,分别是调用Object.wait()、join()方法。处于等待状态的线程,正在等待其他线程去实行一个特定的操作。例如:由于wait()而等待的线程正在等待另一个线程去调用notify()或notifyAll();一个由于join()而等待的线程正在等待另一个线程结束。TIMED_WAITING一个在限定时间内等待的线程的状态。也称之为限时等待状态。造成线程限时等待状态的原因有三种,分别是:Thread.sleep(long),Object.wait(long)、join(long)。TERMINATED一个完全运行完成的线程的状态。也称之为终止状态、结束状态各个状态的转换,如下图所示:

1.2 案例演示

为了验证上面叙述的状态即状态转换的精确性,也为了加深对线程状态转换的理解,下面通过三个案例演示线程间中的状态转换。
1.2.1 案例一

本案例主要演示TIME_WAITING的状态转换。
需求:编写一段代码,依次表现一个线程的这些状态:NEW -> RUNNABLE -> TIME_WAITING -> RUNNABLE ->  TERMINATED
为了简化我们的开发,本次我们利用匿名内部类结合lambda表达式的方式利用多线程。
代码实现
  1. public class ThreadStateDemo01 {
  2.     public static void main(String[] args) throws InterruptedException {
  3.         //定义一个内部线程
  4.         Thread thread = new Thread(() -> {
  5.             System.out.println("2.执行thread.start()之后,线程的状态:" + Thread.currentThread().getState());
  6.             try {
  7.                 //休眠100毫秒
  8.                 Thread.sleep(100);
  9.             } catch (InterruptedException e) {
  10.                 e.printStackTrace();
  11.             }
  12.             System.out.println("4.执行Thread.sleep(long)完成之后,线程的状态:" + Thread.currentThread().getState());
  13.         });
  14.         //获取start()之前的状态
  15.         System.out.println("1.通过new初始化一个线程,但是还没有start()之前,线程的状态:" + thread.getState());
  16.         //启动线程
  17.         thread.start();
  18.         //休眠50毫秒
  19.         Thread.sleep(50);
  20.         //因为thread1需要休眠100毫秒,所以在第50毫秒,thread处于sleep状态
  21.         //用main线程来获取thread1线程的状态,因为thread1线程睡眠时间较长
  22.         //所以当main线程执行的时候,thread1线程还没有睡醒,还处于计时等待状态
  23.         System.out.println("3.执行Thread.sleep(long)时,线程的状态:" + thread.getState());
  24.         //thread1和main线程主动休眠150毫秒,所以在第150毫秒,thread早已执行完毕
  25.         Thread.sleep(100);
  26.         System.out.println("5.线程执行完毕之后,线程的状态:" + thread.getState() + "\n");
  27.     }
  28. }
复制代码
控制台输出
  1. 1.通过new初始化一个线程,但是还没有start()之前,线程的状态:NEW
  2. 2.执行thread.start()之后,线程的状态:RUNNABLE
  3. 3.执行Thread.sleep(long)时,线程的状态:TIMED_WAITING
  4. 4.执行Thread.sleep(long)完成之后,线程的状态:RUNNABLE
  5. 5.线程执行完毕之后,线程的状态:TERMINATED
复制代码
1.2.2 案例二

本案例主要演示WAITING的状态转换。
需求:编写一段代码,依次表现一个线程的这些状态:NEW -> RUNNABLE -> WAITING -> RUNNABLE -> TERMINATED
  1. public class ThreadStateDemo02 {
  2.     public static void main(String[] args) throws InterruptedException {
  3.         //定义一个对象,用来加锁和解锁
  4.         Object obj = new Object();
  5.         //定义一个内部线程
  6.         Thread thread1 = new Thread(() -> {
  7.             System.out.println("2.执行thread.start()之后,线程的状态:" + Thread.currentThread().getState());
  8.             synchronized (obj) {
  9.                 try {
  10.                     //thread1需要休眠100毫秒
  11.                     Thread.sleep(100);
  12.                     //thread1100毫秒之后,通过wait()方法释放obj对象是锁
  13.                     obj.wait();
  14.                     
  15.                 } catch (InterruptedException e) {
  16.                     e.printStackTrace();
  17.                 }
  18.             }
  19.             System.out.println("4.被object.notify()方法唤醒之后,线程的状态:" + Thread.currentThread().getState());
  20.         });
  21.         //获取start()之前的状态
  22.         System.out.println("1.通过new初始化一个线程,但是还没有start()之前,线程的状态:" + thread1.getState());
  23.         //启动线程
  24.         thread1.start();
  25.         //main线程休眠150毫秒
  26.         Thread.sleep(150);
  27.         //因为thread1在第100毫秒进入wait等待状态,所以第150秒肯定可以获取其状态
  28.         System.out.println("3.执行object.wait()时,线程的状态:" + thread1.getState());
  29.         //声明另一个线程进行解锁
  30.         new Thread(() -> {
  31.             synchronized (obj) {
  32.                 //唤醒等待的线程
  33.                 obj.notify();
  34.             }
  35.         }).start();
  36.         //main线程休眠10毫秒等待thread1线程能够苏醒
  37.         Thread.sleep(10);
  38.         //获取thread1运行结束之后的状态
  39.         System.out.println("5.线程执行完毕之后,线程的状态:" + thread1.getState() + "\n");
  40.     }
  41. }
复制代码
控制台输出结果
  1. 1.通过new初始化一个线程,但是还没有start()之前,线程的状态:NEW
  2. 2.执行thread.start()之后,线程的状态:RUNNABLE
  3. 3.执行object.wait()时,线程的状态:WAITING
  4. 4.被object.notify()方法唤醒之后,线程的状态:RUNNABLE
  5. 5.线程执行完毕之后,线程的状态:TERMINATED
复制代码
1.2.3 案例三

本案例主要演示BLOCKED的状态转换。
需求:编写一段代码,依次表现一个线程的这些状态:NEW -> RUNNABLE -> BLOCKED -> RUNNABLE -> TERMINATED
  1. public class ThreadStateDemo03 {
  2.     public static void main(String[] args) throws InterruptedException {
  3.         //定义一个对象,用来加锁和解锁
  4.         Object obj2 = new Object();
  5.         //定义一个线程,先抢占了obj2对象的锁
  6.         new Thread(() -> {
  7.             synchronized (obj2) {
  8.                 try {
  9.                     Thread.sleep(100);              //第一个线程要持有锁100毫秒
  10.                     obj2.wait();                          //然后通过wait()方法进行等待状态,并释放obj2的对象锁
  11.                 } catch (InterruptedException e) {
  12.                     e.printStackTrace();
  13.                 }
  14.             }
  15.         }).start();
  16.         //定义目标线程,获取等待获取obj2的锁
  17.         Thread thread = new Thread(() -> {
  18.             System.out.println("2.执行thread.start()之后,线程的状态:" + Thread.currentThread().getState());
  19.             synchronized (obj2) {
  20.                 try {
  21.                     Thread.sleep(100);              //thread3要持有对象锁100毫秒
  22.                     obj2.notify();                        //然后通过notify()方法唤醒所有在ojb2上等待的线程继续执行后续操作
  23.                 } catch (InterruptedException e) {
  24.                     e.printStackTrace();
  25.                 }
  26.             }
  27.             System.out.println("4.阻塞结束后,线程的状态:" + Thread.currentThread().getState());
  28.         });
  29.         //获取start()之前的状态
  30.         System.out.println("1.通过new初始化一个线程,但是还没有thread.start()之前,线程的状态:" + thread.getState());
  31.         //启动线程
  32.         thread.start();
  33.         //先等100毫秒
  34.         Thread.sleep(50);
  35.         //第一个线程释放锁至少需要100毫秒,所以在第50毫秒时,thread正在因等待obj的对象锁而阻塞
  36.         System.out.println("3.因为等待锁而阻塞时,线程的状态:" + thread.getState());
  37.         //再等300毫秒
  38.         Thread.sleep(300);
  39.         //两个线程的执行时间加上之前等待的50毫秒总共是250毫秒,所以第300毫秒,所有的线程都已经执行完毕
  40.         System.out.println("5.线程执行完毕之后,线程的状态:" + thread.getState());
  41.     }
  42. }
  43. //---------------------代码简化--------------------------------------------
  44. Object obj = new Object();
  45.         Thread t1 = new Thread(()->{
  46.             synchronized (obj){
  47.                 try {
  48.                     Thread.sleep(1000);
  49.                 } catch (InterruptedException e) {
  50.                     e.printStackTrace();
  51.                 }
  52.             }
  53.         });
  54.         t1.start();
  55.         Thread t2 = new Thread(()->{
  56.             System.out.println("线程开启之后的状态" + Thread.currentThread().getState());
  57.             synchronized (obj){
  58.                 System.out.println("进入之后的状态" + Thread.currentThread().getState());
  59.             }
  60.         });
  61.         System.out.println("创建线程对象后,但是不调用start方法的状态" + t2.getState());
  62.         t2.start();
  63.         Thread.sleep(100);
  64.         System.out.println(t2.getState());
  65.         Thread.sleep(2000);
  66.         System.out.println(t2.getState());
复制代码
控制台输出结果
  1. 1.通过new初始化一个线程,但是还没有thread.start()之前,线程的状态:NEW
  2. 2.执行thread.start()之后,线程的状态:RUNNABLE
  3. 3.因为等待锁而阻塞时,线程的状态:BLOCKED
  4. 4.阻塞结束后,线程的状态:RUNNABLE
  5. 5.线程执行完毕之后,线程的状态:TERMINATED
复制代码
通过上面3个案例的代码演示,我们可以证明开始章节说所述的线程状态以及线程状态转换都是精确的。

免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。

本帖子中包含更多资源

您需要 登录 才可以下载或查看,没有账号?立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览

快速回复

您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

嚴華

金牌会员
这个人很懒什么都没写!
快速回复 返回顶部 返回列表