Java100-010:多线程的生产者消费者模式实现（管程法）：借助缓冲区（容器）

package java02;
/**
 *   我的java每天100行代码010
 *  多线程的生产者消费者模式（管程法）：借助缓冲区（容器）
 *  wait，notify,notifyAll
 * @author Administrator
 *
 */
public class java010 {
	public static void main(String[] args) {
		SynContainer sc = new SynContainer();//创建一个容器，消费者和生产者就操作这个容器
		//创建两个多线程(生产者，消费者)
		//这里是继承的thread类，当然也可以通过实现Runnable接口来创建两个多线程
		Productor p = new Productor(sc);
		p.start();
		
		Consumer c = new Consumer(sc);
		c.start();
	}
}

//生产者(多线程)
class Productor extends Thread{
	//生产者往容器中放馒头
	SynContainer sc;
	public Productor(SynContainer sc){
		this.sc = sc;
	}
	
	public void run(){
		//生产的馒头数要和消费的馒头数相同，不然最后生产的馒头没人消费
		for(int i=0;i<100;i++) {
			System.out.println("生产第"+i+"个馒头");
			sc.push(new Steamedbun(i));//馒头是一个对象，把一个馒头传过去
		}
	}
}

//消费者(多线程)
class Consumer extends Thread{
	//消费者消费丢出来的馒头
	SynContainer sc;
	public Consumer(SynContainer sc) {
		this.sc = sc;
	}
	public void run(){
		//生产的馒头数要和消费的馒头数相同，不然最后生产的馒头没人消费
		for(int i=0;i<100;i++) {
			System.out.println("消费第"+sc.pop().id+"个馒头");//pop()返回一个馒头对象，我们消费的是这个馒头
			sc.pop();
		}
	}
}

//容器（存：容器满了就等待，取：容器空了就等待）
class SynContainer{
	Steamedbun[] buns = new Steamedbun[10];
	int count = 0;
	//存
	public synchronized void push(Steamedbun bun){
		//放进来一个馒头
		//容器中没有满，就可以存入数据
		//容器满了，只有等待
		if(count==buns.length) {
			try {
				this.wait();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		buns[count] = bun;//往容器中存数据
		count++;
		//存在数据了，可以通知消费了
		notifyAll();
	}
	//取
	public synchronized Steamedbun pop(){
		//丢出去一个馒头
		//容器中有数据就可以消费
		//容器中没有数据只有等待
		if(count==0) {
			try {
				this.wait();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		count--;
		Steamedbun bun = buns[count];
		//容器有空间了，可以通知生产了
		notifyAll();
		return bun;
	}
}

//馒头(数据)
class Steamedbun{
	int id;//给每个馒头都安上一个标签
	public Steamedbun(int id){
		this.id = id;
	}
}