class Producer implements Runnable {  
 
    private String producerName = null; 
 
    private StoreHouse storeHouse = null; 
 
    public Producer(String producerName, StoreHouse storeHouse) { 
        this.producerName = producerName; 
        this.storeHouse = storeHouse; 
    } 
 
    public void setProducerName(String producerName) { 
        this.producerName = producerName; 
    } 
 
    public String getProducerName() { 
        return producerName; 
    } 
     
    public void produceProduct() { 
        int i = 0; 
        while (true) { 
            i++; 
            Product pro = new Product(i); 
            storeHouse.push(pro); 
            System.out.println(getProducerName() + " 生产了 " + pro); 
            try { 
                Thread.sleep(2000); 
            } catch (InterruptedException e) { 
                return; 
            } 
        } 
    } 
 
    public void run() { 
        produceProduct(); 
    } 
 
} 

class Consumer implements Runnable { 
     
    private String consumerName = null; 
     
    private StoreHouse storeHouse = null; 
 
    public Consumer(String consumerName, StoreHouse storeHouse) { 
        this.consumerName = consumerName; 
        this.storeHouse = storeHouse; 
    } 
     
    public void setConsumerName(String consumerName) { 
        this.consumerName = consumerName; 
    } 
     
    public String getConsumerName() { 
        return consumerName; 
    } 
     
    public void consumerProduct() { 
        while (true) { 
            System.out.println(getConsumerName() + " 消费了 " + storeHouse.pop()); 
            try { 
                Thread.sleep(5000); 
            } catch (InterruptedException e) { 
                return; 
            } 
        } 
    } 
 
    public void run() { 
        consumerProduct(); 
    } 
 
} 


 
class Product { 
 
    private int productId = 0; 
     
    public Product(int productId) { 
        this.productId = productId; 
    } 
 
    public int getProductId() { 
        return productId; 
    } 
 
    public String toString() { 
        return Integer.toString(productId); 
    } 
} 

class StoreHouse { 
 
    private int base = 0; 
 
    private int top = 0; 
 
    private Product[] products = new Product[10]; 
 
    public synchronized void push(Product product) { 
        while (top == products.length) { 
            notify(); 
            try { 
                System.out.println("仓库已满，正等待消费..."); 
                wait(); 
            } catch (InterruptedException e) { 
                System.out.println("stop push product because other reasons"); 

            } 
        } 
        products[top] = product; 
        top++; 
    } 
 
    public synchronized Product pop() { 
        Product pro = null; 
        while (top == base) { 
            notify(); 
            try { 
                System.out.println("仓库已空，正等待生产..."); 
                wait(); 
            } catch (InterruptedException e) { 
                System.out.println("stop push product because other reasons"); 

            } 
        } 
        top--; 
        pro = products[top]; 
        products[top] = null; 
        return pro; 
    } 
} 

public class TestPC { 
    public static void main(String[] args) { 
        StoreHouse storeHouse = new StoreHouse(); 
        Producer producer = new Producer("生产者", storeHouse); 
        Consumer comsumer = new Consumer("消费者", storeHouse); 
        Thread t1 = new Thread(producer); 
        Thread t2 = new Thread(comsumer); 
        t1.start(); 
        t2.start(); 
    } 
}