1、多執行緒通訊

兩個執行緒同時操作一個儲存空間，一個存資料，一讀資料。並且按照一定的順序輪流執行。Object提供wait(),notify(),notify All()，方法用於解決執行緒間通訊問題。

1.1、程式碼

package com.example;


public class MyThreadCommit {
    public static void main (String [] args){

    Storage st = new Storage();//建立資料儲存類物件
    Input input = new Input(st);//建立Input 物件傳入Storage物件
 

        Output output = new Output(st);//建立傳入Ｓｔｏｒａｇｅ物件
        new Thread(input).start();
        new Thread(output).start();
    }
}

class Input implements  Runnable{ //輸入執行緒
    private  Storage st;
    private int num; //定義一個變數
    Input(Storage st){  //通過構造方法來接受一個Ｓｔｏｒａｇｅ物件
        this.st=st;
    }
    public
 
  void  run(){
        while (true){
            st.put(num++); //將num存入陣列，每次存入後　＋１
        }
    }
}

class Output implements  Runnable{//輸出執行緒類
    private Storage st;
    Output(Storage st){
        this.st=st; //構造方法接受一個Storage 物件
    }
    public void run(){
        while(true){
            st.get(); //迴圈取出元素
 

        }
    }

}

class Storage {
    private int [] cells = new int[10]; //資料儲存陣列
    private int inPos,outPos;//inPos 存入時的陣列下標，outPos取出時的陣列下標
    private int count; //存入或取出時資料的數量
    public synchronized void put(int num){
            try {
                while (count == cells.length){
                this.wait(); 
            }
            cells[inPos]=num;//向陣列中放入資料
            System.out.println("在cells["+inPos+"]中放入資料－－－"+cells[inPos]);
            inPos++; //存完元素讓位置加１
            if (inPos == cells.length){
                inPos = 0; //當cells[9]放完資料後再從cells[0]開始
            }
            count ++; //每方一個數據count 加１
            this.notify();
            } catch (InterruptedException e) {
                e.printStackTrace();

        }
    }

    public synchronized  void get(){
            try {
                while (count == 0) { //如果count為０,此執行緒等待
                    this.wait();
                }
                int data = cells[outPos];//從陣列中取出資料
                System.out.println("在cells["+outPos+"]中取出資料－－－"+data);
                cells[outPos]=0;//當取出資料時，當前資料值為０
                outPos++;//取萬後位置+1
                if(outPos == cells.length){
                    outPos=0;//當從cells[9]中取完資料後再從cells[0]開始
                }
                count--;//每取一個元素count -1
                this.notify();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

1.2、執行結果

在cells[2]中放入資料－－－3759862
在cells[3]中放入資料－－－3759863
在cells[4]中放入資料－－－3759864
在cells[5]中放入資料－－－3759865
在cells[6]中放入資料－－－3759866
在cells[7]中放入資料－－－3759867
在cells[8]中放入資料－－－3759868
在cells[9]中放入資料－－－3759869
在cells[0]中放入資料－－－3759870
在cells[1]中取出資料－－－3759861
在cells[2]中取出資料－－－3759862
在cells[3]中取出資料－－－3759863
在cells[4]中取出資料－－－3759864
在cells[5]中取出資料－－－3759865
在cells[6]中取出資料－－－3759866
在cells[7]中取出資料－－－3759867
在cells[8]中取出資料－－－3759868
在cells[9]中取出資料－－－3759869
在cells[0]中取出資料－－－3759870
在cells[1]中放入資料－－－3759871
在cells[2]中放入資料－－－3759872
在cells[3]中放入資料－－－3759873
在cells[4]中放入資料－－－3759874

首先使用synchorized關鍵字將put()方法和get()方法修飾為同步方法，之後每操作一次資料，便呼叫一次notify()方法喚醒　對應同步鎖上等待的執行緒。
當存入資料時，如果count的值和cells陣列的長度相等，說明陣列已經填滿，此時呼叫同步鎖的wait()方法使存入資料的執行緒進入等待狀態。
當取出資料時，如果count的值為０，說明陣列已經被取空，此時就需要呼叫同步鎖的wait()方法，使取出資料的執行緒進入等待狀態。

參考文件：
Java基礎入門　傳智部落格高教產品研發部　

本人鄭重宣告，本部落格所著文章、圖片版權歸權利人持有，本博只做學習交流分享所用，不做任何商業用途。訪問者可將本博提供的內容或服務用於個人學習、研究或欣賞，不得用於商業使用。同時，訪問者應遵守著作權法及其他相關法律的規定，不得侵犯相關權利人的合法權利；如果用於商業用途，須徵得相關權利人的書面授權。若以上文章、圖片的原作者不願意在此展示內容，請及時通知在下，將及時予以刪除。