生产者消费者java实现

package 线程;

import java.util.LinkedList;

public class 生产者消费者 {
private LinkedList storeHouse = new LinkedList();
private int MAX = 10;

public 生产者消费者() {
}

public void start() {
new Producer().start();

new Comsumer().start();
}

class Producer extends Thread {
public void run() {
while (true) {
synchronized (storeHouse) {
try {
while (storeHouse.size() == MAX) {
System.out
.println("storeHouse is full , please wait");
storeHouse.wait();
}
Object newOb = new Object();
if (storeHouse.add(newOb)) {
System.out
.println("Producer put a Object to storeHouse");
Thread.sleep((long) (Math.random() * 3000));
storeHouse.notify();
}
} catch (InterruptedException ie) {
System.out.println("producer is interrupted!");
}

}
}
}
}

class Comsumer extends Thread {
public void run() {
while (true) {
synchronized (storeHouse) {
try {
while (storeHouse.size() == 0) {
System.out
.println("storeHouse is empty , please wait");
storeHouse.wait();
}
storeHouse.removeLast();
System.out
.println("Comsumer get  a Object from storeHouse");
Thread.sleep((long) (Math.random() * 3000));
storeHouse.notify();
} catch (InterruptedException ie) {
System.out.println("Consumer is interrupted");
}

}
}

}
}

public static void main(String[] args) throws Exception {
生产者消费者 pc = new 生产者消费者();
pc.start();
}
}