多线程经典的生产者-消费者实例

以下是java多线程经典的生产者-消费者实例 Java线程：并发协作-生产者消费者模型对于多线程程序来说，不管任何编程语言，生产者和消费者模型都是最经典的。就像学习每一门编程语言一样，Hello World！都是最经典的例子。实际上，准确说应该是“生产者-消费者-仓储”模型，离开了仓储，生产者消费者模型就显得没有说服力了。对于此

hxyerui

1047人浏览 · 2016-01-26 16:11:26

hxyerui · 2016-01-26 16:11:26 发布

以下是java多线程经典的生产者-消费者实例

Java线程：并发协作-生产者消费者模型

对于多线程程序来说，不管任何编程语言，生产者和消费者模型都是最经典的。就像学习每一门编程语言一样，Hello World！都是最经典的例子。

实际上，准确说应该是“生产者-消费者-仓储”模型，离开了仓储，生产者消费者模型就显得没有说服力了。

对于此模型，应该明确一下几点：

1、生产者仅仅在仓储未满时候生产，仓满则停止生产。

2、消费者仅仅在仓储有产品时候才能消费，仓空则等待。

3、当消费者发现仓储没产品可消费时候会通知生产者生产。

4、生产者在生产出可消费产品时候，应该通知等待的消费者去消费。

此模型将要结合java.lang.Object的wait与notify、notifyAll方法来实现以上的需求。这是非常重要的。

/**
 * 仓库
 * 
 * @author yerui 2016年1月21日
 */
public class Storage {
	public static final int max_size = 100;// 满额
	public int currnum; // 当前库存

	public Storage() {

	}

	public Storage(int currnum) {
		this.currnum = currnum;
	}

	/**
	 * 生产指定的产品
	 * 
	 * @param neednum
	 */
	public synchronized void produce(int neednum) {
		while (currnum + neednum > max_size) {
			System.out.println("要生产的产品数量" + neednum + "超过剩余库存量" + (max_size - currnum) + "，暂时不能执行生产任务!");
			try {
				wait();
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		// 满足生产条件，则进行生产，这里简单的更改当前库存量
		currnum += neednum;
		System.out.println("已经生产了" + neednum + "个产品，现仓储量为" + currnum);
		// 唤醒在此对象监视器上等待的所有线程
		notifyAll();
	}

	/**
	 * 需要消费一定量的产品
	 * 
	 * @param neednum
	 */
	public synchronized void consume(int neednum) {
		while (neednum > currnum) {
			try {
				wait();
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}

		}
		// 满足消费条件，则进行消费，这里简单的更改当前库存量
		currnum -= neednum;
		System.out.println("已经生产了" + neednum + "个产品，现仓储量为" + currnum);
		// 唤醒在此对象监视器上等待的所有线程
		notifyAll();
	}

}

/**
 * 生产者
 * 
 * @author yerui 2016年1月21日
 */
public class Producer extends Thread {
	private int neednum;
	private Storage storage;

	public Producer() {

	}

	public Producer(int neednum, Storage storage) {
		super();
		this.neednum = neednum;
		this.storage = storage;
	}

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

}

/**
 * 消费者
 * 
 * @author yerui 2016年1月21日
 */
public class Consumer extends Thread {
	private int neednum;
	private Storage storage;

	public Consumer() {

	}

	public Consumer(int neednum, Storage storage) {
		super();
		this.neednum = neednum;
		this.storage = storage;
	}

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

}

/***
 * 多线程经典的 生产者-消费者 实例
 * @author yerui
 *2016年1月21日
 */
public class Test {
public static void  main(String args[]){
	   Storage  storage = new Storage(30); 
	   Consumer c1 = new Consumer(50,storage);
	   Consumer c2 = new Consumer(30,storage);
	   Consumer c3 = new Consumer(10,storage);
	   Producer p1 = new Producer(10,storage);
	   Producer p2 = new Producer(10,storage);
	   Producer p3 = new Producer(10,storage);
	   Producer p4 = new Producer(20,storage);
	   Producer p5 = new Producer(30,storage);
	   Producer p6 = new Producer(10,storage);
	   Producer p7 = new Producer(100,storage);
	   c1.start(); 
       c2.start(); 
       c3.start(); 
       p1.start(); 
       p2.start(); 
       p3.start(); 
       p4.start(); 
       p5.start(); 
       p6.start(); 
       p7.start(); 
   }
   
  
}