package com.ming.thread.t3.waitandnotify;

import java.util.Date;

import java.util.LinkedList;

import java.util.List;

/**

 * 先建立一个缓冲区的存储

 * @author mingge

 *

 */

public class BufferStorage {

    private int maxSize=0;

    private List<String> list;

    public BufferStorage(int maxSize){

        this.maxSize=maxSize;

        list=new LinkedList<>();

    }

    synchronized public void set(String str){

        while(list.size()==maxSize){//当list中装的数据最大时，就等待消费者线程

            try {

                wait();

            } catch (InterruptedException e) {

                e.printStackTrace();

            }

        }

        list.add(str+":"+new Date().getTime());

         System.out.printf("Set: %d",list.size());

         System.out.println();

        notifyAll();

    }

    synchronized public void get(){

        while(list.size()==0){

            try {

                wait();

            } catch (InterruptedException e) {

                e.printStackTrace();

            }

        }

        System.out.printf("Get: %d: %s",list.size(),((LinkedList<?>)list).poll());  //poll 先得到数据，在remove数据

        notifyAll();

    }

}

package com.ming.thread.t3.waitandnotify;

/**

 * 建立一个生产者线程

 * @author mingge

 *

 */

public class ProducerThread extends Thread{

    BufferStorage bufferStorage;

    public ProducerThread(BufferStorage bufferStorage){

        super();

        this.bufferStorage=bufferStorage;

        super.setName("ProducerThread");

    }

    public void run(){

        for(int i=0;i<200;i++){

            bufferStorage.set("mingge:");

        }

    }

}

package com.ming.thread.t3.waitandnotify;

/**

 * 建立一个消费者线程

 * @author mingge

 *

 */

public class CustomerThread extends Thread{

    BufferStorage bufferStorage;

    public CustomerThread(BufferStorage bufferStorage){

        super();

        this.bufferStorage=bufferStorage;

        super.setName("CustomerThread");

    }

    public void run(){

        for(int i = 0; i < 200; i++) {

            bufferStorage.get();

        }

    }

}

package com.ming.thread.t3.waitandnotify;

public class Test {

    public static void main(String[] args) {

        BufferStorage bufferStorage=new BufferStorage(10);

        ProducerThread producerThread=new ProducerThread(bufferStorage);

        CustomerThread customerThread=new CustomerThread(bufferStorage);

        producerThread.start();

        customerThread.start();

    }

}