java 多線程 wait，notify

selfimpr 發布于2019-08-16 17:44 / 3036人閱讀

摘要：因為涉及到對象鎖，一定要在里面進行使用。必須暫定當前正在執行的線程并釋放資源鎖讓其他線程可以有機會運行喚醒線程共享變量線程通訊標識線程生產者線程消費者請求結果

因為涉及到對象鎖，Wait、Notify一定要在synchronized里面進行使用。

Wait必須暫定當前正在執行的線程,并釋放資源鎖,讓其他線程可以有機會運行

notify/notifyall: 喚醒線程

共享變量

public class ShareEntity {
    private String name;
    // 線程通訊標識
    private Boolean flag = false;

    public ShareEntity() {
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Boolean getFlag() {
        return flag;
    }

    public void setFlag(Boolean flag) {
        this.flag = flag;
    }
}

線程1（生產者）

public class CommunicationThread1 extends Thread{

    private ShareEntity shareEntity;
    public CommunicationThread1(ShareEntity shareEntity) {
        this.shareEntity = shareEntity;
    }

    @Override
    public void run() {
        int num = 0;
        while (true) {
            synchronized (shareEntity) {
                if (shareEntity.getFlag()) {
                    try {
                        shareEntity.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }

                if (num % 2 == 0)
                    shareEntity.setName("thread1-set-name-0");
                else
                    shareEntity.setName("thread1-set-name-1");
                num++;
                shareEntity.setFlag(true);
                shareEntity.notify();
            }
        }
    }
}

線程2（消費者）

public class CommunicationThread2 extends Thread{
    private ShareEntity shareEntity;
    public CommunicationThread2(ShareEntity shareEntity) {
        this.shareEntity = shareEntity;
    }

    @Override
    public void run() {
        while (true) {
            synchronized (shareEntity) {
                if (!shareEntity.getFlag()) {
                    try {
                        shareEntity.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                System.out.println(shareEntity.getName());
                shareEntity.setFlag(false);
                shareEntity.notify();
            }
        }
    }
}

請求

@RequestMapping("test-communication")
    public void testCommunication() {
        ShareEntity shareEntity = new ShareEntity();
        CommunicationThread1 thread1 = new CommunicationThread1(shareEntity);
        CommunicationThread2 thread2 = new CommunicationThread2(shareEntity);
        thread1.start();
        thread2.start();
    }

結果

thread1-set-name-0
thread1-set-name-1
thread1-set-name-0
thread1-set-name-1
thread1-set-name-0
thread1-set-name-1
thread1-set-name-0

GPU云服務器云服務器 Wait-Notify java多線程多線程調試 java java多線程分發

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/74700.html

Java多線程學習（四）等待/通知（wait/notify）機制

摘要：運行可運行狀態的線程獲得了時間片，執行程序代碼。阻塞的情況分三種一等待阻塞運行的線程執行方法，會把該線程放入等待隊列中。死亡線程方法執行結束，或者因異常退出了方法，則該線程結束生命周期。死亡的線程不可再次復生。系列文章傳送門: Java多線程學習（一）Java多線程入門 Java多線程學習（二）synchronized關鍵字（1） java多線程學習（二）synchronized關鍵...

PiscesYE 2019-08-15 15:30 評論0 收藏0
Java 多線程編程之：notify 和 wait 用法

摘要：和簡介和均為的方法暫停一個線程喚醒一個線程從以上的定義中，我們可以了解到以下事實想要使用這兩個方法，我們需要先有一個對象。在中任何一個時刻，對象的控制權只能被一個線程擁有。若有多個線程處于此控制權下的狀態，只有一個會被喚醒。最近看帖子，發現一道面試題：啟動兩個線程, 一個輸出 1,3,5,7…99, 另一個輸出 2,4,6,8…100 最后 STDOUT 中按序輸出 1,2,3,4...

eccozhou 2019-08-19 11:32 評論0 收藏0
Java多線程基礎（一）——線程與鎖

摘要：一線程的基本概念單線程簡單的說，單線程就是進程中只有一個線程。多線程由一個以上線程組成的程序稱為多線程程序。當線程調用完方法進入后會自動釋放鎖，線程獲得鎖。一、線程的基本概念 1.1 單線程簡單的說，單線程就是進程中只有一個線程。單線程在程序執行時，所走的程序路徑按照連續順序排下來，前面的必須處理好，后面的才會執行。 Java示例： public class SingleThrea...

WelliJhon 2019-08-16 12:40 評論0 收藏0
Java 多線程核心技術梳理(附源碼)

摘要：本文對多線程基礎知識進行梳理，主要包括多線程的基本使用，對象及變量的并發訪問，線程間通信，的使用，定時器，單例模式，以及線程狀態與線程組。源碼采用構建，多線程這部分源碼位于模塊中。通知可能等待該對象的對象鎖的其他線程。本文對多線程基礎知識進行梳理，主要包括多線程的基本使用，對象及變量的并發訪問，線程間通信，lock的使用，定時器，單例模式，以及線程狀態與線程組。寫在前面花了一周時...

Winer 2019-08-16 11:46 評論0 收藏0
java 多線程編程核心技術 3—線程間通信

摘要：在從返回前，線程與其他線程競爭重新獲得鎖。就緒隊列存儲了將要獲得鎖的線程，阻塞隊列存儲了被阻塞的線程。當線程呈狀態，調用線程對象的方法會出現異常。在執行同步代碼塊過程中，遇到異常而導致線程終止，鎖也會被釋放。方法wait()的作用是使當前執行代碼的線程進行等待，wait()方法是Object類的方法，該方法用來將當前線程置入預執行隊列中,并且在wait()所在的代碼行處停止執行，直...

Dogee 2019-08-15 13:35 評論0 收藏0
java多線程（7）wait()、notify()和notityALL()

摘要：已經在上面有提到過，和的作用是喚醒正在的線程，是隨機喚醒線程中的一個，則是喚醒全部。釋放和不釋放鎖在多線程的操作中，鎖的釋放與否是必須要清楚的，是會釋放鎖，而則不會。 wait wait方法是Object中的方法，這個方法的功能特性：1).執行wait方法的前提是當前線程已經獲取到對象的鎖，也就是wait方法必須在synchronized修飾的代碼塊或者方法中使用。2).執行wait之...

LiuRhoRamen 2019-08-19 10:43 評論0 收藏0