Java并發編程之線程狀態實例分析

今天小編給大家分享一下Java并發編程之線程狀態實例分析的相關知識點，內容詳細，邏輯清晰，相信大部分人都還太了解這方面的知識，所以分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后有所收獲，下面我們一起來了解一下吧。

線程狀態概述

線程由生到死的完整過程：

當線程被創建并啟動以后，它既不是一啟動就進入了執行狀態，也不是一直處于執行狀態。在線程的生命周期中，有幾種狀態呢？在API中java.lang.Thread.State這個枚舉中給出了六種線程狀態：

睡眠sleep方法

狀態中有一個狀態叫做計時等待，可以通過Thread類的方法來進行演示。 public static void sleep(long time) 讓當前線程進入到睡眠狀態，到毫秒后自動醒來繼續執行

//主線程執行到sleep方法會休眠1秒后再繼續執行
public class Test{
  public static void main(String[] args){
    for(int i = 1;i<=5;i++){
      	Thread.sleep(1000);
        System.out.println(i)   
    } 
  }
}

等待和喚醒

public void wait() : 讓當前線程進入到等待狀態 此方法必須鎖對象調用。

public class Demo1_wait {
    public static void main(String[] args) throws InterruptedException {
	   // 步驟1 : 子線程開啟,進入無限等待狀態, 沒有被喚醒,無法繼續運行.
        new Thread(() -> {
            try {

                System.out.println("begin wait ....");
                synchronized ("") {
                    "".wait();
                }
                System.out.println("over");
            } catch (Exception e) {
            }
        }).start();
    }

public void notify() : 喚醒當前鎖對象上等待狀態的線程 此方法必須鎖對象調用。

public class Demo2_notify {
    public static void main(String[] args) throws InterruptedException {
	   // 步驟1 : 子線程開啟,進入無限等待狀態, 沒有被喚醒,無法繼續運行.
        new Thread(() -> {
            try {

                System.out.println("begin wait ....");
                synchronized ("") {
                    "".wait();
                }
                System.out.println("over");
            } catch (Exception e) {
            }
        }).start();

        //步驟2:  加入如下代碼后, 3秒后,會執行notify方法, 喚醒wait中線程.
        Thread.sleep(3000);
        new Thread(() -> {
            try {
                synchronized ("") {
                    System.out.println("喚醒");
                    "".notify();
                }
            } catch (Exception e) {
            }
        }).start();
    }
}

等待喚醒的一個小例子

定義一個集合，包子鋪線程完成生產包子，包子添加到集合中；吃貨線程完成購買包子，包子從集合中移除。

• 當包子沒有時（包子狀態為false），吃貨線程等待.

• 包子鋪線程生產包子（即包子狀態為true），并通知吃貨線程（解除吃貨的等待狀態）

public class BaoZiPu extends Thread{
    private List<String> list ;
    public BaoZiPu(String name,ArrayList<String> list){
        super(name);
        this.list = list;
    }
    @Override
    public void run() {
        	int i = 0; 
            while(true){
                    //list作為鎖對象
                    synchronized (list){
                        if(list.size()>0){
                            //存元素的線程進入到等待狀態
                            try {
                                list.wait();
                            } catch (InterruptedException e) {
                                e.printStackTrace();
                            }
                        }

                        //如果線程沒進入到等待狀態 說明集合中沒有元素
                        //向集合中添加元素
                        list.add("包子"+i++);
                        System.out.println(list);
                        //集合中已經有元素了 喚醒獲取元素的線程
                        list.notify();
                    }
                }
            }
    }
}

public class ChiHuo extends Thread {

    private List<String> list ;
    public ChiHuo(String name,ArrayList<String> list){
        super(name);
        this.list = list;
    }

    @Override
    public void run() {
 			//為了能看到效果 寫個死循環
                while(true){
                    //由于使用的同一個集合 list作為鎖對象
                    synchronized (list){
                        //如果集合中沒有元素 獲取元素的線程進入到等待狀態
                        if(list.size()==0){
                            try {
                                list.wait();
                            } catch (InterruptedException e) {
                                e.printStackTrace();
                            }
                        }
                        //如果集合中有元素 則獲取元素的線程獲取元素(刪除)
                        list.remove(0);
                        //打印集合 集合中沒有元素了
                        System.out.println(list);
                        //集合中已經沒有元素 則喚醒添加元素的線程 向集合中添加元素
                        list.notify();
                    }
                }
            }
    }
}

public class Demo {
    public static void main(String[] args) {
        //等待喚醒案例
        List<String> list = new ArrayList<>();
        // 創建線程對象        
         BaoZiPu bzp = new BaoZiPu("包子鋪",list);
        ChiHuo ch = new ChiHuo("吃貨",list);
        // 開啟線程
        bzp.start();
        ch.start();
    }
}

以上就是“Java并發編程之線程狀態實例分析”這篇文章的所有內容，感謝各位的閱讀！相信大家閱讀完這篇文章都有很大的收獲，小編每天都會為大家更新不同的知識，如果還想學習更多的知識，請關注億速云行業資訊頻道。