成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

java 多線程 wait，notify

selfimpr / 3045人閱讀

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

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

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

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（生產(chǎn)者）

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();
    }

結(jié)果

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

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/74700.html

相關(guān)文章

  • Java多線程學(xué)習(xí)（四）等待/通知（wait/notify）機制

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

    PiscesYE 評論0 收藏0

  • Java 多線程編程之：notify 和 wait 用法

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

    eccozhou 評論0 收藏0

  • Java多線程基礎(chǔ)（一）——線程與鎖

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

    WelliJhon 評論0 收藏0

  • Java 多線程核心技術(shù)梳理(附源碼)

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

    Winer 評論0 收藏0

  • java 多線程編程核心技術(shù) 3—線程間通信

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

    Dogee 評論0 收藏0

  • java多線程（7）wait()、notify()和notityALL()

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

    LiuRhoRamen 評論0 收藏0

發(fā)表評論

0條評論

最新活動
閱讀需要支付1元查看
<