[Java] BlockingQueue

简介

java.util.concurrent 包里的 BlockingQueue 是一个接口，继承 Queue 接口，Queue 接口继承 Collection 接口。

特性

解析

1. 异常：如果试图的操作无法立即执行，抛一个异常。
2. 特定值：如果试图的操作无法立即执行，返回一个特定的值(常常是 true / false)。
3. 阻塞：如果试图的操作无法立即执行，该方法调用将会发生阻塞，直到能够执行。
4. 超时：如果试图的操作无法立即执行，该方法调用将会发生阻塞，直到能够执行，但等待时间不会超过给定值，返回一个特定值以告知该操作是否成功（典型的是 true / false）。

实现类

1. ArrayBlockingQueue：一由数组结构组成的有界阻塞队列。
2. DelayQueue：支持延时获取元素的无界阻塞队列。
3. LinkedBlockingQueue：由链表结构组成的有界阻塞队列。
4. PriorityBlockingQueue：支持优先级排序的无界阻塞队列。
5. SynchronousQueue：不存储元素的阻塞队列。

SynchronousQueue

SynchronousQueue 也是一个队列来的，但它的特别之处在于它内部没有容器，一个生产线程，当它生产产品（即 put 的时候），如果当前没有人想要消费产品（即当前没有线程执行take），此生产线程必须阻塞，等待一个消费线程调用 take 操作，take 操作将会唤醒该生产线程，同时消费线程会获取生产线程的产品（即数据传递），这样的一个过程称为一次配对过程（当然也可以先 take 后 put，原理是一样的）。

子接口

1. BlockingDeque
2. TransferQueue

增加的方法

1. boolean add(E e)
2. boolean contains(Object o)
3. int drainTo(Collection<? super E> c)
4. int drainTo(Collection<? super E> c, int maxElements)
5. boolean offer(E e)
6. boolean offer(E e, long timeout, TimeUnit unit)
7. E poll(long timeout, TimeUnit unit)
8. void put(E e)
9. int remainingCapacity()
10. boolean remove(Object o)
11. E take()