2.5多线程（Java学习笔记）生产者消费者模式

public class Buffer {
    private int index = 0;
    private int MAX = 5;  //定义缓冲区的最大存储量
    private Phone pa[] = new Phone[MAX];//定义存储产品的数组
    
    synchronized public void consumer(){  //消费者方法，要加synchronized获得锁。
        if(index <= 0){                   //如果缓冲区没有资源，当前线程等待并释放锁。
            try {                         //如果该线程被其他线程唤醒并获得锁，从wait()之后继续执行
                wait();
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }          //消费时一定要注意先--，因为必定先生产后才能消费，而生产后由于++的原因会多加一个1，所以这里需要多减一个1.
        System.out.println("消费手机：" + pa[--index].getPhoneNum()); //仓库有货或被其他线程唤醒（生产者是先生产再唤醒的，所以唤醒后缓冲区必有货物）后消费产品
        notify();   //消费后唤醒生产者线程。这里的唤醒只是通知下你可以抢夺锁了，但也不一定抢到。如果生产者没有抢到锁消费者会继续消费。          
    }               //如果没有货了，消费者自己会等待，然后生产者自然回去生产。
                    //锁只有执行完synchronized范围才会释放锁。wait（）是可以直接立刻马上释放锁，而且之后的语句也不执行，之后的语句等到下一次被其他线程并获得锁后才执行。
    synchronized public void producer(Phone p){//生产者，接受来自生产线程生产的产品。
        if(index >= MAX){  //如果缓冲区已满，则释放锁并等待。
            try {
                wait();
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        pa[index++] = p;  //将生产的产品放在数组中，放入后要加1 ，仓库没有满或被消费者线程叫醒（被消费者叫醒说明消费者消费了产品，则缓冲区必定没有满）后生产产品。
        System.out.println("生产手机：" + p.getPhoneNum());
        notify();   //生产后，唤醒消费者消费
    }
}

public class Producer implements Runnable{  //生产者线程需要实现Runnable接口
    private int i = 0;
    private Buffer b;                  //创建缓冲区对象。
    
    public void setBuffer(Buffer b){   //添加构造方法获得缓冲区对象。
        this.b = b;
    }
    
    
    public void run(){                 //生产者线程生产20个产品
        for(i = 0; i < 20; i++){
            b.producer(new Phone(i));  //生产者线程将产品放入缓冲区
        }
    }    
}

public class Consumer implements Runnable{
    private Buffer b;
    
    public void setBuffer(Buffer b){  //通过方法设置缓冲区对象
        this.b = b;
    }
    
    public void run(){               //消费者线程
        for(int i = 0; i < 20; i++){  //消费20个产品
            b.consumer();             //进入缓冲区拿产品
        }
    }
}

public class ProCon {
    public static void main(String[] args) {
        Buffer b = new Buffer();  //建立缓冲区
        
        Consumer c = new Consumer(); //建立消费者线程
        c.setBuffer(b);              //在消费者线程中放入缓冲区对象
        Producer p = new Producer();  //建立生产者线程
        p.setBuffer(b);               //在生产者线程中放入缓冲区对象
        
        new Thread(c).start();
        new Thread(p).start();
    }
}

运行结果：
生产手机：0
生产手机：1
生产手机：2
生产手机：3
生产手机：4
消费手机：4
消费手机：3
消费手机：2
消费手机：1
消费手机：0
生产手机：5
生产手机：6
生产手机：7
生产手机：8
生产手机：9
消费手机：9
消费手机：8
消费手机：7
消费手机：6
消费手机：5
生产手机：10
生产手机：11
生产手机：12
生产手机：13
生产手机：14
消费手机：14
消费手机：13
消费手机：12
消费手机：11
消费手机：10
生产手机：15
生产手机：16
生产手机：17
生产手机：18
生产手机：19
消费手机：19
消费手机：18
消费手机：17
消费手机：16
消费手机：15