1. ConcurrentLinkedQueue

Queue的一个线程安全实现，见下：
public class ConcurrentLinkedQueue<E> extends AbstractQueue<E> implements Queue<E>, java.io.Serializable {}

2.BlockingQueue 阻塞队列

这是一个线程安全的接口，见下：

public interface BlockingQueue<E> extends Queue<E>

它的一些常用方法见下：

void java.util.concurrent.BlockingQueue.put(E e)

put方法在队列满的时候会阻塞，直到有队列成员被消费。

E java.util.concurrent.BlockingQueue.take()

take方法在队列空的时候会阻塞，直到有队列成员被放进来。

int java.util.concurrent.BlockingQueue.drainTo(Collection<? super E> c)

把队列中的元素倾倒给实参c。适用于生产者一直生产，消费者定时消费的场景。如果消费者的消费行为是IO操作，那么定时可以达到缓存效果，节省IO。

它有两个实现类，LinkedBlockingQueue与ArrayBlockingQueue。

public class LinkedBlockingQueue<E> extends AbstractQueue<E> implements BlockingQueue<E>, java.io.Serializable {}

由于LinkedBlockingQueue实现是线程安全的，实现了先进先出等特性，是作为生产者消费者的首选。LinkedBlockingQueue 可以指定容量，也可以不指定，不指定的话，默认最大是Integer.MAX_VALUE。

它是阻塞队列的另外一个实现，见下：

public class ArrayBlockingQueue<E> extends AbstractQueue<E> implements BlockingQueue<E>, java.io.Serializable {}