當前位置 : IT培訓網 > Java開發 > Java教程 > Java線程間如何進行通信

Java線程間如何進行通信

時間:2016-08-30 14:46:43??來源:Java培訓網??作者:IT培訓網??已有:名學員訪問該課程
為避免輪詢,Java包含了通過wait( ),notify( )和notifyAll( )方法實現的一個進程間通信機制。這些方法在對象中是用final方法實現的,所以所有的類都含有它們。這三個方法僅在synchronized方法中才能被調用。盡管這些方法從計算機科學遠

Java線程間通信是非常復雜的問題的。線程間通信問題本質上是如何將與線程相關的變量或者對象傳遞給別的線程,從而實現交互。對于這方面的知識點我們該如何學習呢?

像前面所討論過的,多線程通過把任務分成離散的和合乎邏輯的單元代替了事件循環程序。線程還有第二優點:它遠離了輪詢。輪詢通常由重復監測條件的循環實現。一旦條件成立,就要采取適當的行動。這浪費了CPU時間。舉例來說,考慮經典的序列問題,當一個線程正在產生數據而另一個程序正在消費它。為使問題變得更有趣,假設數據產生器必須等待消費者完成工作才能產生新的數據。在輪詢系統,消費者在等待生產者產生數據時會浪費很多CPU周期。一旦生產者完成工作,它將啟動輪詢,浪費更多的CPU時間等待消費者的工作結束,如此下去。很明顯,這種情形不受歡迎。

為避免輪詢,Java包含了通過wait( ),notify( )和notifyAll( )方法實現的一個進程間通信機制。這些方法在對象中是用final方法實現的,所以所有的類都含有它們。這三個方法僅在synchronized方法中才能被調用。盡管這些方法從計算機科學遠景方向上來說具有概念的高度先進性,實際中用起來是很簡單的:

wait( ) 告知被調用的線程放棄管程進入睡眠直到其他線程進入相同管程并且調用notify( )。

notify( ) 恢復相同對象中第一個調用 wait( ) 的線程。

notifyAll( ) 恢復相同對象中所有調用 wait( ) 的線程。具有最高優先級的線程最先運行。

 

這些方法在Object中被聲明,如下所示:

    final void wait( ) throws InterruptedException

    final void notify( )

    final void notifyAll( )

wait( )存在的另外的形式允許你定義等待時間。

 

下面的例子程序錯誤的實行了一個簡單生產者/消費者的問題。它由四個類組成:Q,設法獲得同步的序列;Producer,產生排隊的線程對象;Consumer,消費序列的線程對象;以及PC,創建單個Q,Producer,和Consumer的小類。

// An incorrect implementation of a producer and consumer.

class Q {

    int n;

    synchronized int get() {

        System.out.println("Got: " + n);

        return n;

    }

    synchronized void put(int n) {

        this.n = n;

        System.out.println("Put: " + n);

    }

}

class Producer implements Runnable {

    Q q;

    Producer(Q q) {

        this.q = q;

        new Thread(this, "Producer").start();

    }

    public void run() {

        int i = 0;

        while(true) {

            q.put(i++);

        }

    }

}

class Consumer implements Runnable {

    Q q;

    Consumer(Q q) {

        this.q = q;

        new Thread(this, "Consumer").start();

    }

    public void run() {

        while(true) {

           q.get();

        }

    }

}

class PC {

    public static void main(String args[]) {

        Q q = new Q();

        new Producer(q);

        new Consumer(q);

        System.out.println("Press Control-C to stop.");

    }

}

盡管Q類中的put( )和get( )方法是同步的,沒有東西阻止生產者超越消費者,也沒有東西阻止消費者消費同樣的序列兩次。這樣,你就得到下面的錯誤輸出(輸出將隨處理器速度和裝載的任務而改變):

Put: 1

Got: 1

Got: 1

Got: 1

Got: 1

Got: 1

Put: 2

Put: 3

Put: 4

Put: 5

Put: 6

Put: 7

Got: 7

生產者生成1后,消費者依次獲得同樣的1五次。生產者在繼續生成2到7,消費者沒有機會獲得它們。

用Java正確的編寫該程序是用wait( )和notify( )來對兩個方向進行標志,如下所示:

// A correct implementation of a producer and consumer.

class Q {

    int n;

    boolean valueSet = false;

    synchronized int get() {

        if(!valueSet)

            try {

                wait();

            } catch(InterruptedException e) {

                System.out.println("InterruptedException caught");

            }

            System.out.println("Got: " + n);

            valueSet = false;

            notify();

            return n;

        }

        synchronized void put(int n) {

            if(valueSet)

            try {

                wait();

            } catch(InterruptedException e) {

                System.out.println("InterruptedException caught");

            }

            this.n = n;

            valueSet = true;

            System.out.println("Put: " + n);

            notify();

        }

    }

    class Producer implements Runnable {

        Q q;

        Producer(Q q) {

        this.q = q;

        new Thread(this, "Producer").start();

    }

    public void run() {

        int i = 0;

        while(true) {

            q.put(i++);

        }

    }

}

class Consumer implements Runnable {

    Q q;

    Consumer(Q q) {

        this.q = q;

        new Thread(this, "Consumer").start();

    }

    public void run() {

        while(true) {

            q.get();

        }

    }

}

class PCFixed {

    public static void main(String args[]) {

        Q q = new Q();

        new Producer(q);

        new Consumer(q);

        System.out.println("Press Control-C to stop.");

    }

}

內部get( ), wait( )被調用。這使執行掛起直到Producer 告知數據已經預備好。這時,內部get( ) 被恢復執行。獲取數據后,get( )調用notify( )。這告訴Producer可以向序列中輸入更多數據。在put( )內,wait( )掛起執行直到Consumer取走了序列中的項目。當執行再繼續,下一個數據項目被放入序列,notify( )被調用,這通知Consumer它應該移走該數據。

下面是該程序的輸出,它清楚的顯示了同步行為:

Put: 1

Got: 1

Put: 2

Got: 2

Put: 3

Got: 3

Put: 4

Got: 4

Put: 5

Got: 5

好了,關于Java線程間如何進行通信就介紹到這里了,如果想要學習的更深入些,請關注達內IT培訓網,小編等你來欣賞最新最全的Java教程。

頂一下
(1)
100%
踩一下
(0)
0%
------分隔線----------------------------
------分隔線----------------------------
Java教程
1、Java 概述
1.1 Java語言概述
1.2 Java虛擬機以及跨平臺原理
1.3 Java的主要就業方向
1.4 Java的不同版本
1.5 Java開發環境搭建
1.6 第一個Java程序示例
1.7 Java類和對象的概念
1.8 Java類庫及其組織結構
1.9 Java import
2、Java 語法基礎
2.1 Java數據類型以及變量的定義
2.2 Java數據類型轉換
2.3 Java運算符
2.4 Java流程控制
2.5 Java數組的定義和使用
2.6 Java字符串(String)
2.7 Java StringBuffer與StringBuider
2.8 強調一下編程風格
3、Java 類與對象
3.1 Java類的定義及其實例化
3.2 Java訪問修飾符
3.3 Java變量的作用域
3.4 Java this關鍵字詳解
3.5 Java方法重載
3.6 Java類的基本運行順序
3.7 Java包裝類、拆箱和裝箱詳解
3.8 再談Java包
3.9 源文件的聲明規則
4、Java 繼承和多態
4.1 繼承的概念與實現
4.2 Java super關鍵字
4.3 繼承中的方法的覆蓋和重載
4.4 多態和動態綁定
4.5 instanceof 運算符
4.6 多態對象的類型轉換
4.7 Java static關鍵字
4.8 Java final關鍵字
4.9 Java Object類
5、面向對象高級特性
5.1 Java內部類及其實例化
5.2 內部類的分類
5.3 抽象類的概念和使用
5.4 接口的概念和使用
5.5 接口和抽象類的區別
5.6 Java 泛型
5.7 泛型通配符和類型參數的范圍
6、異常處理
6.1 異常處理基礎
6.2 異常類型Java語言中常見的異常類型有哪些
6.3 未被捕獲的異常
6.4 try和catch的使用
6.5 多重catch語句的使用
6.6 try語句的嵌套
6.7 throw:異常的拋出
6.8 throws子句
6.9 finally塊
6.10 Java的內置異常
6.11 創建自己的異常子類
6.12 斷言
7、線程編程
7.1 線程的概念
7.2 Java線程模型
7.3 主線程
7.4 創建線程
7.5 創建多線程
7.6 isAlive()和join()的使用
7.7 線程優先級
7.8 線程同步
7.9 線程間通信
7.10 線程死鎖
7.11 線程的掛起、恢復和終止
8、輸入輸出(IO)操作
8.1 輸入輸出基本概念
8.2 面向字符的輸入流
8.3 面向字符的輸出流
8.4 面向字節的輸入輸出流
8.5 面向字節流的應用
8.6 文件與目錄管理
8.7 文件的隨機讀寫
8.8 文件的壓縮處理
9、常用類庫、向量與哈希
9.1 Java基礎類庫
9.2 Object類
9.3 Java語言包(java.lang)簡介
9.4 日期和時間類
9.5 向量及其應用
9.6 哈希表及其應用
10、圖形界面(GUI)設計
10.1 圖形界面設計基礎
10.2 框架窗口
10.3 標簽、按鈕和按鈕事件
10.4 面板
10.5 布局設計
10.6 文本框和文本區
10.7 文本框和文本區的輸入輸出
10.8 選擇框和單選按鈕
10.9 列表和組合框
10.10 菜單
10.11 對話框
10.12 滾動條
10.13 鼠標事件
10.14 鍵盤事件
11、圖形、圖像與多媒體
11.1 繪圖基礎
11.2 設置字型和顏色
11.3 繪圖模式
11.4 Graphics類的繪圖方法
11.5 Graphics2D類的繪圖方法
11.6 圖像處理基礎
11.7 圖像緩沖技術
11.8 多媒體基礎
12、網絡與數據庫編程
12.1 IP地址和InetAddress類
12.2 統一資源定位符
12.3 套接字(Socket)
12.4 數據庫連接
12.5 幾個重要的類和接口
12.6 數據庫查詢
12.7 數據庫更新
12.8 插入記錄
12.9 修改記錄
12.10 刪除記錄
激情色播