Java中的阻塞队列（2）

6、同步队列SynchronousQueue

    同步队列是一个不存储元素的阻塞队列，每一个put操作必须等待一个take操作，否则就不能继续添加元素。这种场景下可用于多个线程之间的通讯，a线程可以把需要传递的数据放到同步队列中，b线程消费队列中的数据，因为本身不存储元素，所以SynchronousQueue的吞吐量高于ArrayBlockingQueue和LinkedBlockingQueue

    首先看一下结构，从结构上跟别的队列并没有什么太大的区别，所以区别就要看里面的源码了

图6-1

    SynchronousQueue队列分为两种模式默认采取的非公平锁，SynchronousQueue不存储元素，所以会有很多的生产者和消费者阻塞，对于这些阻塞的线程，非公平锁中存入了一个LIFO队列中，其实就是把线程放入队列，而不是数据

    当SynchronousQueue构造函数中入口参数改为true，此时队列采取公平锁，阻塞的线程存入一个FIFO队列中

    此处具一个例子

图6-2 图6-3

7、LinkedBlockingDeque链表双向阻塞队列

    由链表结构组成的双向阻塞队列，双向队列指的是可以从队列的两端插入和移出元素

8、链表传输队列LinkedTransferQueue

    这个需要重点说一下，首先看一下类组成结构如图8-1

图8-1

    此处我们单独拿出TransferQueue接口所扩展的方法来看这个传输队列的作用，如图8-2

图8-2

        我们可以看到TransferQueue接口扩展的几个方法：

            1、transfer(E e) ：如果目前有消费者阻塞，则直接移交消费者，如果没有，放到队列尾部且生产者进入阻塞，直到数据被消费

            2、tryTransfer(E e)：如果目前有消费者阻塞，则直接移交消费者，如果没有，直接返回false，而且数据不进入队列，这个操作不会阻塞线程

            3、tryTransfer(E e,long timeOut,TimeUnit unit)：如果目前有消费者阻塞，则直接移交消费者，如果没有，放到队列尾部且生产者进入阻塞，等到消费者来消费，如果指定时间中无法被消费者获取，则直接返回false，同时元素被移除

            4、hasWaitingConsumer()：判断有没有等待的消费者

            5、getWaitingConsumerCount()：获取目前存在的消费者的数量

    知道了这些，基本就能大概了解到这个实现TransferQueue接口的类大多能做什么了，接下来直接上一个简单的应用

    如图8-3

图8-3 图8-4 图8-5