java中Queue

在并发队列中JDK提供了两种队列:数组

ConcurrentLinkedQueue:支持高性能的Queue缓存

BlockingQueue:带阻塞的Queue安全


ConcurrentLinkedQueue是一种适用于高并发场景下的队列,经过无锁的方式,实现高并发状态下的高性能,一般性能优于BlockingQueue.是一种基于链接节点的***线程安全队列。遵循FIFO原则,不容许NULL.注意:size 方法不是 一个固定时间操做。因为这些队列的异步特性,肯定当前元素的数量须要遍历这些元素。并发

add:将指定的元素插入到此队列中(若是当即可行且不会违反容量限制),在成功时返回 true,若是当前没有可用空间,则抛出 IllegalStateException异步

offer: 将指定元素插入到此队列的尾部(若是当即可行且不会超出此队列的容量),在成功时返回 true,若是此队列已满,则返回 falseide

poll:获取并移除此队列的头,若是此队列为空,则返回 null函数

peek:获取但不移除此队列的头;若是此队列为空,则返回 null高并发


BlockingQueue接口
性能


ArrayBlockingQueue是一钟基于数组的阻塞队列实现,其维护一个指定长度的数组,以便缓存队列中的数据对象,内部没有实现读写分离。能够指定访问策略。线程


LinkedBlockingQueue基于链表的阻塞队列,内部链表实现,是一种***的队列(建立无需指定长度)。内部实现了读写分离。


SynchronousQueue一种没有缓存的队列,生产者生产的数据直接会被消费者获取并消费。


PriorityBlockingQueue基于优先级的阻塞队列(优先级的判断经过构造函数传入的Compator对象决定,要求传入对象实现Comparable接口),其内部控制线程同步的锁采用的是公平锁,也是一种***队列


DelayQueue带延迟时间的Queue,其中元素只有当其指定的延迟时间到了,才能在队列中获取到该元素。其中的元素须要实现Delayed接口。是一个***队列。

相关文章
相关标签/搜索