java多线程总结六：经典生产者消费者问题实现

package demo.thread;

/**
*经典生产者与消费者问题：生产者不断的往仓库中存放产品，消费者从仓库中消费产品。
*其中生产者和消费者都可以有若干个。仓库容量有限，库满时不能存放，库空时不能取产品
*/

public class ProducersAndConsumers {
public static void main(String[] args) {
Storage storage = new Storage();
Thread consumer = new Thread(new Consumer(storage));
consumer.setName("消费者");
Thread producer = new Thread(new Producer(storage));
producer.setName("生产者");
consumer.start();
producer.start();
}
}

/**
* 消费者
*/
class Consumer implements Runnable {
private Storage storage;

public Consumer(Storage storage) {
this.storage = storage;
}

@Override
public void run() {
storage.pop();
}
}

/**
* 生产者
*/
class Producer implements Runnable {
private Storage storage;

public Producer(Storage storage) {
this.storage = storage;
}

@Override
public void run() {
Product product = new Product("090505105", "电话");
storage.push(product);
}

}

/**
* 产品类
*/
class Product {
private String id;// 产品id
private String name;// 产品名称

public Product(String id, String name) {
this.id = id;
this.name = name;
}

@Override
public String toString() {
return "(产品ID：" + id + " 产品名称：" + name + ")";
}

public String getId() {
return id;
}

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

public String getName() {
return name;
}

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

}

/**
*仓库
*/
class Storage {
// 仓库容量为10
private Product[] products = new Product[10];
private int top = 0;

// 生产者往仓库中放入产品
public synchronized void push(Product product) {
while (top == products.length) {
try {
wait();//仓库已满，等待
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
//把产品放入仓库
products[top++] = product;
System.out.println(Thread.currentThread().getName() + " 生产了产品"
+ product);
notifyAll();//唤醒等待线程

}

// 消费者从仓库中取出产品
public synchronized Product pop() {
while (top == 0) {
try {
wait();//仓库空，等待
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

}

//从仓库中取产品
--top;
Product p = new Product(products[top].getId(), products[top].getName());
products[top] = null;
System.out.println(Thread.currentThread().getName() + " 消费了产品" + p);
notifyAll();//唤醒等待线程
return p;
}
}