幽灵工作室提供
对于多线程程序来说，不管任何编程语言，生产者和消费者模型都是最经典的。就像学习每一门编程语言一样，Hello World!都是最经典的例子。
实际上，准确说应该是“生产者-消费者-仓储”模型，离开了仓储，生产者消费者模型就显得没有说服力了。
对于此模型，应该明确一下几点：
1、生产者仅仅在仓储未满时候生产，仓满则停止生产。
2、消费者仅仅在仓储有产品时候才能消费，仓空则等待。
3、当消费者发现仓储没产品可消费时候会通知生产者生产。
4、生产者在生产出可消费产品时候，应该通知等待的消费者去消费。
此模型将要结合java.lang.Object的wait与notify、notifyAll方法来实现以上的需求。这是非常重要的
package youling.studio.producerandconsumer;
public class Main {
public static void main(String[] args) throws InterruptedException {
Godown godown = new Godown(1000, 40);
new Thread(new Consumer(50, godown)).start();
new Thread(new Consumer(100, godown)).start();
new Thread(new Consumer(10, godown)).start();
new Thread(new Producer(30, godown)).start();
new Thread(new Producer(50, godown)).start();
new Thread(new Producer(10, godown)).start();
new Thread(new Producer(80, godown)).start();
new Thread(new Producer(20, godown)).start();
new Thread(new Producer(20, godown)).start();
new Thread(new Producer(30, godown)).start();
new Thread(new Consumer(100, godown)).start();
Thread.sleep(10000);
System.out.println("当前的库存:"+godown.curNum);
}
}
class Godown{
public Integer maxSize = 1000;//库容量
public Integer curNum ;//当前库存
public Godown() {
}
public Godown(Integer curNum) {
super();
this.curNum = curNum;
}
public Godown(Integer maxSize, Integer curNum) {
super();
this.maxSize = maxSize;
this.curNum = curNum;
}
public synchronized void produce(Integer needNum){
//测试是够需要生产
while(needNum+curNum>maxSize){
System.out.println("要生产的产品数量" + needNum + "超过剩余库存量" + (maxSize - curNum) + "，暂时不能执行生产任务!");
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
//满足条件的时候,进行生产
curNum += needNum;
System.out.println("已经生产了" + needNum + "个产品，现仓储量为" + curNum);
//唤醒消费者
notifyAll();
}
public synchronized void consume(Integer needNum){
//测试库存数量是够够实用的
while(curNum < needNum){//此处实用while的原因是因为,如果一个线程在此处等待,被唤醒后就会执行下面的代码,跳出if,而条件可能依旧不满足,所以让线程醒来后继续判断一下,如果满足了继续执行,如果不满足继续等待
try {
System.out.println("库存不够,等待生产.");
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
//满足条件的时候,进行消费
curNum -= needNum;
System.out.println("已经消费了" + needNum + "个产品，现仓储量为" + curNum);
//唤醒在此对象监视器上等待的所有线程
notifyAll();
}
}
class Producer implements Runnable{
private Integer needNum;//要生产的数量
private Godown godown;//共享的仓库,构造传进来
public Producer(Integer needNum, Godown godown) {
this.needNum = needNum;
this.godown = godown;
}
@Override
public void run() {
godown.produce(needNum);//生产商品
}
}
class Consumer implements Runnable{
private Integer needNum;
private Godown godown;
public Consumer(Integer needNum, Godown godown) {
this.needNum = needNum;
this.godown = godown;
}
@Override
public void run() {
godown.consume(needNum);//消费指定数量的库存
}
}