如何实现生产者消费者模型?

• 简单来说就是使用阻塞队列来实现该模型
• 阻塞队列的实现:

1. 阻塞队列依旧是一个先进先出的队列
2. 入队列时如果发现队列满了,就会阻塞,直到其他线程调用出队列操让队列有空位之后 ,才能继续入队列
3. 出队列的时候如果发现队列为空,也会阻塞, 直到其他线程调用入队列操作rag队列有元素,才能继续出队列

实现阻塞队列

//阻塞队列 public class BlockingQueue { private int[] array = new int[20]; private int haed = 0; private int tail = 0; private volatile int size = 0; //put向队列放元素 public void put(int val) throws InterruptedException { synchronized (this) { while (this.size == array.length) { this.wait(); }              array[tail] = val;             tail++;             size++; if (tail == array.length) { this.tail = 0; } this.notify(); } } //take取队首元素 public int take() throws InterruptedException { int ret; synchronized (this) { while (this.size == 0) { this.wait(); }              ret = array[haed];             haed++;             size--; if (haed == array.length) { this.haed = 0; } this.notify(); } return ret; } } 

代码分析

• 详细说一下为什么判断空或者满要使用while而不是使用if
  假设现在又三个线程 一个生产 俩个消费
  而且是消费快 生产慢
  此时俩个消费都会判断为空然后进入wait
  如果此时我们不小心使用了notiAll唤醒了所有等待的线程
  于是消费者1先得到锁 执行了出队列操作 生产者还没来得及生产 消费者2就又获取了锁 此时刚刚生产了一个元素已经被消费者拿走了 当前已经是一个空队列了
  如果再往下执行就会发生逻辑错误 结果就不可控了
• 所以我们在判断条件进行使用wait的时候 都推荐使用while去搭配而不是if