Java中设计模式之生产者消费者模式-3

约定不等于承诺〃 2022-06-17 11:57 185阅读 0赞

# 引言 #

生产者-消费者（producer-consumer）问题，也称作有界缓冲区（bounded-buffer）问题，两个进程共享一个公共的固定大小的缓冲区。其中一个是生产者，用于将消息放入缓冲区；另外一个是消费者，用于从缓冲区中取出消息。问题出现在当缓冲区已经满了，而此时生产者还想向其中放入一个新的数据项的情形，其解决方法是让生产者此时进行休眠，等待消费者从缓冲区中取走了一个或者多个数据后再去唤醒它。同样地，当缓冲区已经空了，而消费者还想去取消息，此时也可以让消费者进行休眠，等待生产者放入一个或者多个数据时再唤醒它。

# 生产者消费者模型 #

四个类

> 1.产品类：面包，饮料等  
> 2.资源类（中介类）：超市（买卖各种产品）  
> 3.生产类（工厂类）：生产各种产品  
> 4.消费者类（顾客类）：消费各种产品

# 代码： #

## 1.产品类 ##

package 设计模式之生产者消费者模式;
    
    public class Bread {
        
        private String brand;
        private double price;
        public String getBrand() {
            return brand;
        }
        public void setBrand(String brand) {
            this.brand = brand;
        }
        public double getPrice() {
            return price;
        }
        public void setPrice(double price) {
            this.price = price;
        }
        @Override
        public String toString() {
            return "Bread [brand=" + brand + ", price=" + price + "]";
        }
        public Bread(String brand, double price) {
            super();
            this.brand = brand;
            this.price = price;
        }
        public Bread() {
            super();
        }
    
    }

## 2.中介类（资源类）：超市 ##

负责统筹安排所有资源，是生产者和消费者的桥梁。类似多线程中的共享资源，各个线程来操作同一个资源。

package 设计模式之生产者消费者模式;
    
    public class Market {
    //假设超市买面包的容量为6（即面包货架容量为6）
        private Bread[] breads=new Bread[6];
        int index=-1;// 为什么不默认为0  因为数组下标为0 是有一个数据的
        //从工厂进面包
        public synchronized void getBread(Bread bread){
            //如果昨天生意不好，没有卖出面包，此时就不需要进货
            if(index>=5){
       // 下标如果大于等于5 那就是有6个面包  工厂不需要生产  所以让工厂等着
                try {
                    this.wait();
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
            //生意很好，卖出了面包，需要进货
            // 为了不覆盖任何面包   需要先加 下标 后赋值
            index++;
            //将进的面包放进数组里（货架上）
            breads[index]=bread;
            System.out.println("进了"+breads[index]);
            //进货后，（通知）让顾客消费
            this.notify();
        }
        // 卖面包
        public synchronized void saleBread(){
            //如果昨天生意很好，面包已经卖完了，那么顾客就需要等待
            if(index<0){
       // 下标小于0 就证明是 数组中没有面包了  ,就让消费者等待
                try {
                    this.wait();
                } catch (InterruptedException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
            //有面包可以卖
            //  卖了哪个面包
            System.out.println("[卖了]"+breads[index]);
            // 卖完面包  下标自动减-
            index--;
            this.notify();
        }
    
    }

## 3.工厂类 ##

package 设计模式之生产者消费者模式;
    
    public class Factory implements Runnable {
        
        Market market;
    
        public Factory(Market market) {
            super();
            this.market = market;
        }
        @Override
        public void run() {
            for(int i=0;i<80;i++){
                market.getBread(new Bread("桃李牌"+i, 4.5));
            }
        }
    }

## 4.消费者 ##

package 设计模式之生产者消费者模式;
    
    public class Customer implements Runnable {
        
        Market market;
        public Customer(Market market){
            this.market=market;
        }
    
        @Override
        public void run() {
            for(int i=0;i<80;i++){
                market.saleBread();
            }
        }
    
    }

## 测试类 ##

package 设计模式之生产者消费者模式;
    
    public class Test {
        public static void main(String[] args){
            Market market=new Market();
            Factory factory=new Factory(market);
            Customer customer=new Customer(market);
            Thread thread=new Thread(factory,"生产者");
            Thread thread2=new Thread(customer,"消费者");
            thread.start();
            thread2.start();
        }
    }