Java多線程通訊---------wait,notify區別

来源:https://www.cnblogs.com/losemyfuture/archive/2018/07/24/9357846.html
-Advertisement-
Play Games

小紅,女小紅,女小紅,女小紅,女小紅,女小紅,女小紅,女小紅,女小紅,女 出現以上結果??消費者一直消費或者生產者一直生產 解決方法:生產者生產完成後消費者方可消費,否者不可消費,消費者未消費或者未消費完生產者不可生產,一次生產一次消費。其實也就是保證對res共用資源的操作同一時刻僅有同一個線程進行 ...


class Res{
    public String username;
    public String sex;
}
class Out extends Thread{
    Res res;

    public Out(Res res){
        this.res=res;
    }
    @Override
    public void run() {
        //寫操作
        int count=0;
        while (true){
//            synchronized (res.getClass()){
                if(count==0){//偶數
                    res.username="小明";
                    res.sex="男";
                } else {//奇數
                    res.username="小紅";
                    res.sex="女";
                }
                count=(count+1)%2;
//            }
            }

    }
}
class Input extends Thread{
    Res res;
    public Input(Res res){
        this.res=res;
    }

    @Override
    public void run() {
        while (true){
//            synchronized (res.getClass()){
                System.out.println(res.username+","+res.sex);
//            }
        }
    }
}
public class OutInputThread {
    public static void main(String[] args) {
        Res res = new Res();
        Out out = new Out(res);
        Input input = new Input(res);
        out.start();
        input.start();
    }
}

小紅,女
小紅,女
小紅,女
小紅,女
小紅,女
小紅,女
小紅,女
小紅,女
小紅,女



 

出現以上結果??消費者一直消費或者生產者一直生產

解決方法:生產者生產完成後消費者方可消費,否者不可消費,消費者未消費或者未消費完生產者不可生產,一次生產一次消費。其實也就是保證對res共用資源的操作同一時刻僅有同一個線程進行操作,

wait、notify、notifyAll方法

wait、notify、notifyAll是三個定義在Object類里的方法,可以用來控制線程的狀態。

這三個方法最終調用的都是jvm級的native方法。隨著jvm運行平臺的不同可能有些許差異。

 如果對象調用了wait方法就會使持有該對象的線程把該對象的控制權交出去,然後處於等待狀態。當前線程從運行變為阻塞,釋放所的資源

如果對象調用了notify方法就會通知某個正在等待這個對象的控制權的線程可以繼續運行。讓持有該鎖的線程從阻塞態變為就緒。

如果對象調用了notifyAll方法就會通知所有等待這個對象控制權的線程繼續運行。

註意:一定要線上程同步中使用,並且是同一個鎖的資源

通過以下方式即可完成需求。

生產者獲取res.getClass鎖後,如果flag為true生產者通過調用res.getClass.wait進行等待,此時其他線程可獲取該鎖,如果flag為false,進行生產,然後設置flag為true保證資源消費後方可再生產,接著通過notify通知其他喚醒其他線程。

class Res{
    public String username;
    public String sex;
    //true 生產者等待,消費者可消費 false生產者可以生產,消費者不可消費
    public boolean flag=false;
}
class Out extends Thread{
    Res res;

    public Out(Res res){
        this.res=res;
    }
    @Override
    public void run() {
        //寫操作
        int count=0;
        while (true){
            synchronized (res.getClass()){
                if(res.flag){
                    try {
                        res.getClass().wait();//讓當前線程從運行變為阻塞,並且釋放所的資源
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                if(count==0){//偶數
                    res.username="小明";
                    res.sex="男";
                } else {//奇數
                    res.username="小紅";
                    res.sex="女";
                }
                count=(count+1)%2;
                res.flag=true;
                res.getClass().notify();
            }
            }

    }
}
class Input extends Thread{
    Res res;
    public Input(Res res){
        this.res=res;
    }

    @Override
    public void run() {
        while (true){
            synchronized (res.getClass()){
                if(!res.flag){
                    try {
                        res.getClass().wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                System.out.println(res.username+","+res.sex);
                res.flag=false;
                res.getClass().notify();
            }
        }
    }
}
public class OutInputThread {
    public static void main(String[] args) {
        Res res = new Res();
        Out out = new Out(res);
        Input input = new Input(res);
        out.start();
        input.start();
    }
}


輸出如下:
小明,男
小紅,女
小明,男
小紅,女
小明,男
小紅,女
小明,男
小紅,女

如果去掉notify會怎樣?去掉一個?去掉兩個?

去掉一個生產者可以列印多個(但是也不多),去掉消費者僅可列印一個,去掉兩個可能不列印,也可能列印1個,所以wait、notify必須成對使用

wait(用於同步中)與sleep區別?

都是做休眠,wait需要notify

對於sleep方法,我們首先要知道該方法是屬於Thread類中的。而wait方法,則是屬於Object類中的。

sleep方法導致了程式暫停執行指定的時間,讓出cpu該其他線程,但是他的監控狀態依然保持者,當指定的時間到了又會自動恢復運行狀態。

在調用sleep方法的過程中,線程不會釋放對象鎖。

而當調用wait方法的時候,線程會放棄對象鎖,進入等待此對象的等待鎖定池,只有針對此對象調用notify方法後本線程才進入對象鎖定池準備獲取對象鎖進入運行狀態。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 最近很長時間沒寫博客了,其實這個博客寫過一半,中間有事耽擱了,就沒繼續。主要是給別人做了一個小系統,及維護碼雲上的代碼庫。同居的日子也占了我很多時間。 最近也是煩,欠了7W,各種煩事。所以可想寫個博客靜靜心。 在面向對象中關註的焦點是對象空間,對象與對象的聯繫還是通過保存引用(相當於路),來走到其空 ...
  • 目的是為了可維護、可復用、可擴展、靈活性好 以四則運算為例: 先有個父類運算類: ...
  • 1、什麼是 對象-關係映射 對象-關係映射(Object Relational Mapping,簡稱ORM,對象關係映射)是一種為瞭解決面向對象與關係資料庫存在的互不匹配的現象的技術。 簡單的說,ORM是通過使用描述對象和資料庫之間映射的元數據,將程式中的對象自動持久化到關係資料庫中。本質上就是將數 ...
  • 軟敏捷開發框架V7.0全新升級功能更全,運行更穩定。新版本增加了多語言,首頁動態設置、移動端代碼生成以及大量實用組件。 IM、工作流、代碼生成器也進行了重構,用起來好得不得了! 還等什麼,快去官網看看吧! 主要更新的功能: 新增 1.多語言功能; 2.代碼生成器模版; a.可編輯列表代碼生成器(Ex ...
  • 九、位元組流與字元流 9.1 IO的分類 輸入流 :把數據從其他設備上讀取到記憶體中的流。 輸出流 :把數據從記憶體 中寫出到其他設備上的流。 位元組流 :以位元組為單位,讀寫數據的流。 字元流 :以字元為單位,讀寫數據的流。 輸入流 輸出流 位元組流 位元組輸入流 InputStream 位元組輸出流 Outpu ...
  • 題意 。。。求最短路 Sol 前幾天寫dijkstra的時候沒打vis標記居然A了,然後天真的我就以為Dijkstra不用打標記。 事實上dijkstra真的不用打標記,只不過會被卡成SPFA的複雜度 ...
  • 關鍵點: 一、 二、 beans 配置 ...
  • synchronized:代碼開始上鎖,代碼結束時釋放鎖;內置鎖、自動化的、效率低、擴展性不高(不夠靈活); JDK1.5併發包Lock鎖 保證線程安全問題,屬於手動擋,手動開始上鎖,手動釋放鎖,靈活性高; Lock 介面與 synchronized 關鍵字的區別 Lock 介面可以嘗試非阻塞地獲取 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...