Java中的阻塞队列BlockingQueue

阅读数:115 评论数:0

跳转到新版页面

分类

python/Java

正文

一、概述

在队列为空时，获取元素的线程会等待队列变为非空。当队列满时，存储元素的线程会等待队列可用。阻塞队列常用于生产者和消费者的场景。

阻塞队列提供了四种处理方法：

方法\处理方式	抛出异常	返回特殊值	一直阻塞	超时退出
插入方法	add(e)	offer(e)	put(e)	offer(e,time,unit)
移除方法	remove()	poll()	take()	poll(time,unit)
检查方法	element()	peek()	不可用	不可用

二、ArrayBlockingQueue

是用数组实现的有界阻塞队列，此队列按照FIFO的原则进行排序。支持公平锁和非公平锁（每一个线程在获取锁的时候可能会排队等待，如果在等待时间上，先获取锁的线程的请求一定先被满足，那么这个锁就是公平的。反之，这个锁就是不公平的）。

三、LinkedBlockingQueue

一个由链表结构组成的有界队列，此队列的长度为Integer.MAX_VALUE，FIFO。

如果你想要一次性地从 LinkedBlockingQueue 中取出所有元素，可以使用drainTo()方法

LinkedBlockingQueue<String> queue = new LinkedBlockingQueue<>();
// 假设队列已经被填充了数据

List<String> list = new ArrayList<>();
queue.drainTo(list); // 将队列中的所有元素移动到list中

// 此时，list包含了之前在queue中的所有元素，queue变为空

四、PriorityBlockingQueue

一个支持线程优先级排序的无界队列，可以自定义实现compareTo()方法来指定元素排序规则，不能保证同优先级元素的顺序。

五、DelayQueue

基于PriorityBlockingQueue的延迟获取队列，在创建元素时，可以指定多久才能从队列中获取当前元素，只有延时期满后才能从队列中获取元素。

六、SynchronousQueue

一个不存储元素的阻塞队列，每一个put操作必须等待take操作，否则不能添加元素。

七、LinkedTransferQueue

采用一种预占模式，意思就是消费者线程取元素时，如果队列不为空，则直接取走数据，若队列为空，那就生成一个节点（节点元素为null）入队，然后消费者线程被等待在这个节点上，后面生产者线程入队时发现有一个元素为null的节点，生产者线程就不入队了，直接就将元素填充到该节点，并唤醒该节点等待的线程，被唤醒的消费者线程取走元素，从调用的方法返回。我们称这种节点操作为“匹配”方式。

八、LinkedBlockingDeque

一个由链表结构组成的双向阻塞队列。

秒吧学习