java线程：生产者消费者模式(管程法)

不念不忘少年蓝@ 2022-01-29 18:51 167阅读 0赞

# 组成 #

*  商品(Shop)
 *  仓库(Warehouse：存储商品)
 *  生产者(Producer：生产商品，当仓库容量不够时等待消费者消费商品)；
 *  消费者(Consumer：消费者，当仓库数量不够时等待生产者生产商品)；

## 生产者 ##

/**
     * 生产者
     * @author Administrator
     *
     */
    class Producer implements Runnable{
    	Warehouse wh;
    	
    	public Producer(Warehouse wh) {
    		this.wh = wh;
    	}
    	@Override
    	public void run() {
    		// 生产
    		for(int i=0;i<10;i++) {
    			System.out.println("生产第" + i + "个商品");
    			wh.push(new Shop(i));
    		}
    	}
    }

## 消费者 ##

/**
     * 消费者
     * @author Administrator
     *
     */
    class Consumer implements Runnable{
    	Warehouse wh;
    	public Consumer(Warehouse wh) {
    		this.wh = wh;
    	}
    	@Override
    	public void run() {
    		// 消费
    		for(int i=0;i<10;i++) {
    			System.out.println("消费第" + wh.get().id + "个商品");
    		}
    	}
    }

## 仓库 ##

/**
     * 仓库
     * @author Administrator
     *
     */
    class Warehouse{
    	Shop[] shops = new Shop[10];
    	int count = 0;
    	// 生产
    	public synchronized void push(Shop shop) {
    		if(count == shops.length) {
    			try {
    				this.wait();// 商品数量==仓库可存数量时暂停生产
    			} catch (InterruptedException e) {
    				e.printStackTrace();
    			}
    		}
    		// 当仓库有空间时可以生产
    		shops[count] = shop;
    		count ++;
    		this.notifyAll();// 当生产商品时开始消费
    	}
    	// 消费
    	public synchronized Shop get() {
    		if(count == 0) {
    			try {
    				this.wait(); // 商品==0时等待
    			} catch (InterruptedException e) {
    				e.printStackTrace();
    			}
    		}
    		// 当仓库有商品时可以消费
    		count --;
    		Shop shop = shops[count];
    		this.notifyAll();// 当消费商品时开始生产
    		return shop;
    	}
    }

## 商品 ##

/**
     * 商品
     * @author Administrator
     *
     */
    class Shop{
    	
    	int id;
    	
    	public Shop(int id) {
    		this.id = id;
    	}
    }

## 测试 ##

/**
     * 生产者消费者模式
     * @author Administrator
     *
     */
    public class Test5 {
    
    	public static void main(String[] args) {
    		Warehouse wh = new Warehouse();
    		new Thread(new Producer(wh)).start();
    		new Thread(new Consumer(wh)).start();
    	}
    	
    }

## 输出结果 ##

生产第0个商品
    生产第1个商品
    生产第2个商品
    生产第3个商品
    生产第4个商品
    消费第3个商品
    生产第5个商品
    消费第4个商品
    生产第6个商品
    消费第5个商品
    生产第7个商品
    消费第6个商品
    生产第8个商品
    生产第9个商品
    消费第7个商品
    消费第9个商品
    消费第8个商品
    消费第2个商品
    消费第1个商品
    消费第0个商品