java实现生产者与消费者问题
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();
}
}