您的位置:首页 > 编程语言 > Java开发

设计模式-生产者与消费者Java实现

2014-06-14 22:05 531 查看
幽灵工作室提供
问题去新浪博客留言:http://weibo.com/youlingR
对于多线程程序来说,不管任何编程语言,生产者和消费者模型都是最经典的。就像学习每一门编程语言一样,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);
}
}

/**
* 仓库类
* @author Administrator
*
*/
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;
}
/**
* 生产指定数量的库存
* @param needNum
*/
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();
}
/**
* 消费指定数量的库存
* @param needNum
*/
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);//消费指定数量的库存
}

}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息