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

本人郑重声明，本博客所著文章、图片版权归权利人持有，本博只做学习交流分享所用，不做任何商业用途。访问者可將本博提供的內容或服务用于个人学习、研究或欣赏，不得用于商业使用。同時，访问者应遵守著作权法及其他相关法律的规定，不得侵犯相关权利人的合法权利；如果用于商业用途，须征得相关权利人的书面授权。若以上文章、图片的原作者不愿意在此展示內容，请及时通知在下，將及时予以刪除。