Goods.java
package com.bebig.producerconsumer;

//商品
public class Goods {
    private int id;

    public Goods(int id) {
        this.setId(id);
    }

    public void setId(int id) {
        this.id = id;
    }

    public int getId() {
        return id;
    }
}
Cart.java
package com.bebig.producerconsumer;

//購(gòu)物車
public class Cart {
    private final int MAXVALUE = 6;// 購(gòu)物車?yán)镒疃嗄艽娣诺纳唐窋?shù)量
    private int index = 0;
    private Goods[] goods = new Goods[MAXVALUE];

    public synchronized void push(String name, Goods g) {
        while (index == goods.length) {
            // 購(gòu)物車?yán)餄M了就不要放物品進(jìn)來(lái)了
            try {
                System.out.println("----購(gòu)物車?yán)锏纳唐芬褲M,停止生產(chǎn).");
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        this.notifyAll();
        this.goods[index] = g;
        index++;
        System.out.println("生產(chǎn)者" + name + "向購(gòu)物車?yán)锓胖昧艘患唐?");

    }

    public synchronized Goods pop(String name) {
        while (0 == index) {
            // 購(gòu)物車?yán)锟樟司筒灰∥锲烦鋈チ?/span>
            try {
                System.out.println("----購(gòu)物車?yán)锏纳唐芬芽?停止消費(fèi).");
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        this.notifyAll();
        index--;
        System.out.println("消費(fèi)者" + name + "從購(gòu)物車取走了一件商品.");
        return this.goods[index];
    }

}
Producer.java
package com.bebig.producerconsumer;

//生產(chǎn)者
public class Producer implements Runnable {
    private Cart cart = null;
    private String name;

    public Producer(Cart c, String name) {
        this.cart = c;
        this.setName(name);
    }

    @Override
    public void run() {
        for (int i = 1; i < 10; i++) {
            cart.push(this.getName(), new Goods(i));
            try {
                Thread.sleep((int) (Math.random() * 1000));
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getName() {
        return name;
    }
}
Consumer.java
package com.bebig.producerconsumer;

//消費(fèi)者
public class Consumer implements Runnable {
    private Cart cart = null;
    private String name;

    public Consumer(Cart c, String name) {
        this.name = name;
        this.cart = c;
    }

    @Override
    public void run() {
        for (int i = 1; i < 10; i++) {
            cart.pop(this.getName());
            try {
                Thread.sleep((int) (Math.random() * 1000));
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getName() {
        return name;
    }

}
測(cè)試代碼：
package com.bebig.producerconsumer;

//測(cè)試
public class ProducerAndConsumer {

    /**
     * @param args
     */
    public static void main(String[] args) {
        Cart c = new Cart();

        Producer p1 = new Producer(c, "Don");
        Consumer c1 = new Consumer(c, "Scan");
        Producer p2 = new Producer(c, "txc");
        Consumer c2 = new Consumer(c, "Sun");
        new Thread(p1).start();
        new Thread(c1).start();
        new Thread(p2).start();
        new Thread(c2).start();

    }

}
測(cè)試結(jié)果（隨機(jī)顯示）：
生產(chǎn)者Don向購(gòu)物車?yán)锓胖昧艘患唐?
生產(chǎn)者txc向購(gòu)物車?yán)锓胖昧艘患唐?
消費(fèi)者Sun從購(gòu)物車取走了一件商品.
消費(fèi)者Scan從購(gòu)物車取走了一件商品.
----購(gòu)物車?yán)锏纳唐芬芽?停止消費(fèi).
生產(chǎn)者txc向購(gòu)物車?yán)锓胖昧艘患唐?
消費(fèi)者Sun從購(gòu)物車取走了一件商品.
----購(gòu)物車?yán)锏纳唐芬芽?停止消費(fèi).
生產(chǎn)者txc向購(gòu)物車?yán)锓胖昧艘患唐?
消費(fèi)者Scan從購(gòu)物車取走了一件商品.
生產(chǎn)者Don向購(gòu)物車?yán)锓胖昧艘患唐?
生產(chǎn)者Don向購(gòu)物車?yán)锓胖昧艘患唐?
生產(chǎn)者txc向購(gòu)物車?yán)锓胖昧艘患唐?
消費(fèi)者Sun從購(gòu)物車取走了一件商品.
消費(fèi)者Scan從購(gòu)物車取走了一件商品.
生產(chǎn)者Don向購(gòu)物車?yán)锓胖昧艘患唐?
生產(chǎn)者txc向購(gòu)物車?yán)锓胖昧艘患唐?
消費(fèi)者Sun從購(gòu)物車取走了一件商品.
生產(chǎn)者txc向購(gòu)物車?yán)锓胖昧艘患唐?
消費(fèi)者Scan從購(gòu)物車取走了一件商品.
生產(chǎn)者txc向購(gòu)物車?yán)锓胖昧艘患唐?
生產(chǎn)者Don向購(gòu)物車?yán)锓胖昧艘患唐?
生產(chǎn)者txc向購(gòu)物車?yán)锓胖昧艘患唐?
消費(fèi)者Scan從購(gòu)物車取走了一件商品.
消費(fèi)者Scan從購(gòu)物車取走了一件商品.
消費(fèi)者Sun從購(gòu)物車取走了一件商品.
生產(chǎn)者Don向購(gòu)物車?yán)锓胖昧艘患唐?
生產(chǎn)者txc向購(gòu)物車?yán)锓胖昧艘患唐?
消費(fèi)者Sun從購(gòu)物車取走了一件商品.
消費(fèi)者Scan從購(gòu)物車取走了一件商品.
消費(fèi)者Sun從購(gòu)物車取走了一件商品.
消費(fèi)者Scan從購(gòu)物車取走了一件商品.
----購(gòu)物車?yán)锏纳唐芬芽?停止消費(fèi).
生產(chǎn)者Don向購(gòu)物車?yán)锓胖昧艘患唐?
消費(fèi)者Sun從購(gòu)物車取走了一件商品.
----購(gòu)物車?yán)锏纳唐芬芽?停止消費(fèi).
生產(chǎn)者Don向購(gòu)物車?yán)锓胖昧艘患唐?
消費(fèi)者Scan從購(gòu)物車取走了一件商品.
----購(gòu)物車?yán)锏纳唐芬芽?停止消費(fèi).
生產(chǎn)者Don向購(gòu)物車?yán)锓胖昧艘患唐?
消費(fèi)者Sun從購(gòu)物車取走了一件商品.