目录

一. 什么是阻塞队列

二. java中的阻塞队列

三. 生产者消费者模型

3.1 生产者消费者模型与阻塞队列密不可分的关系

3.2 阻塞队列在生产者消费者模型的作用

a. 解耦合

b. 削峰填谷

四. 模拟实现阻塞队列

 4.1 实现put方法

4.2 实现take方法

4.3 生产者消费者模型​

五.总结

---

一. 什么是阻塞队列

阻塞队列是具有阻塞特性的队列, 它是线程安全的.

阻塞特性:

1. 出队列时, 如果队列为空, 此时就会阻塞, 直到向队列中添加元素为止.

2. 入队列时, 如果队列满了, 此时也会阻塞, 直到从队列中移出元素为止.

---

二. java中的阻塞队列

java中的阻塞队列是一个接口(BlockingQueue<T>), 常用的实例化类有:

1. ArrayBlockingQueue<>(capacity); // 顺序表

2. LinkedBlockingQueue<>(capacity); // 链表

3. PriorityBlockingQueue<>(capacity); // 优先级队列

带有阻塞效果的放取: put(), take().

---

三. 生产者消费者模型

3.1 生产者消费者模型与阻塞队列密不可分的关系

阻塞对列是生产者消费者模型的交易场所.

3.2 阻塞队列在生产者消费者模型的作用

a. 解耦合

解耦合之前, 服务器A直接和服务器B进行交互, 一旦服务器A中的代码发生了改变, 服务器B也需要做出相应的改变.(AB之间关系紧密)

解耦合之后, 服务器A不再与服务器B直接关联, 而是通过阻塞队列来进行交互, 降低了AB之间的关联度.

b. 削峰填谷

 如果A传输给B的数据量激增, 而B没有这么大的接收能力, 就会导致服务器断线.

此时, 引入阻塞队列, 激增的数据就会在阻塞队列中进行缓冲, 输入给B的数据量不会超出B的接收能力.

---

四. 模拟实现阻塞队列

 4.1 实现put方法

重点解读:

synchronized: 保证put操作的原子性.

while: 进行多次判断, 防止notify之后循环队列还是满的, 而导致之后的操作没有意义.

if(tail >= data.length): 表示一次循环已经结束了, 再从头开始.

this.notify(): 此时队列中有元素了, 可以进行take操作.

4.2 实现take方法

重点解读: 

synchronized: 保证take操作的原子性

while: 进行多次判断, 防止notify之后队列还是空的, 导致后面的操作无意义.

4.3 生产者消费者模型        

---

五.总结

1. 什么是阻塞队列(阻塞队列时带有阻塞效果的队列, 是线程安全的)

2. 阻塞队列的实例化(ArrayBlockingQueue, LinkedBlockingQueue, PriorityBlockingQueue)

3. 生产者消费者模型与阻塞队列密不可分的关系(阻塞队列是生产者消费者模型的交易场所)

4. 阻塞队列在生产者消费者模型的作用(解耦合, 削峰填谷)

4. 模拟实现阻塞队列