Queue:一个先进先出的数据结构,与List,Set同一级别,都继承了Collection接口。 JDK提供了两套实现队列,一个是以ConcurrentLinkedQueue为代表的高性能队列,一个是以BlockingQueue接口为代表的阻塞队列。
一、没有实现阻塞接口的LinkedList:实现了java.util.Queue接口和java.util.AbstractQueue接口: ConcurrentLinkedQueue:是一个适用于高并发场景下的队列,通过无锁的方式,实现了高并发状态下的高性能,通常ConcurrentLinkedQueue性能好于BlockingQueue。它是一个基于链接节点的无界线程安全队列,并发访问不需要同步。该队列的元素遵循先进先出,不允许有null元素。 Add()和offer()都是加入元素的方法(在ConcurrentLinkedQueue中,这两个方法没有任何区别) Poll()和peek()都是取头元素节点,区别在于前者会删除元素,后者不会。
PriorityQueue:维护了一个有序列表,加入到Queue中的元素根据它们的天然排序(通过其java.util.Comparable 实现)或者根据传递给构造函数的 java.util.Comparator 实现来定位。
二、实现阻塞接口BlockingQueue接口的阻塞队列类:
ArrayBlockingQueue:基于数组的阻塞队列的实现,内部维护了一个定长数组,以便缓存队列中的数据对象,没有实现读写分离,意味着生产和消费不能同时进行,长度需要定义,可以指定先进先出还是先进后出,也叫有界队列。LinkedBlockingQueue:基于链表的阻塞队列,内部由一个链表维持着数据缓冲队列。之所以能高效的处理并发数据,是因为其内部实现了分离锁(读写分离两个锁),从而实现生产和消费完全并行运行,是一个无界队列。SynchronousQueue:一种没有数据缓存的队列,生产出来的数据直接会被消费掉。PriorityBlockingQueue:基于优先级的阻塞队列(优先级的判断通过构造函数传入的Compator对象来决定,也就是传入队列的对象必须实现Comparable接口)。内部控制线程同步的锁是公平锁,也是一个无界队列。 注意:公平锁是保证每个线程都能拿到锁,不会出现有线程饿死的情况。DelayQueue:带有延迟时间的Queue,其中的元素只有当其指定的延迟时间到了,才能够从队列中获取到该元素。DelayQueue中的元素必须实现Delayed接口,DelayQueue是一个没有大小限制的队列,可应用于对缓存超时的数据进行移除,任务超时处理,空闲连接的关闭。三、Deque双端队列 Deque允许在队列的头部和尾部进行出队和入队操作。 LinkedBlockingDeque是一个线程安全的双端队列实现,最复杂,在内部实现维护了前端和后端节点,但没有实现读写分离,因此同一时间只能有一个线程对其进行操作。在高并发中性能要远低于其他。
四、队列的基本操作的区别 1. add和offer区别: 两者都是向队列中添加一个元素。一些队列有大小限制,如果在一个满的队列中加入一个新元素,add方法会抛出一个unchecked异常,而调用offer方法则会返回false,便于在程序中进行有效的判断。 2. poll和remove区别: remove和poll方法都是从队列中删除第一个元素。如果队列为空,remove方法会抛出异常,但新的poll方法在空集合调用时只是返回null,便于在程序中进行处理。 3. element和peek区别: element和peek用于在队列的头部查询元素。在队列为空时,element会抛出一个异常,而peek返回null。
其他的方法: put:添加一个元素,如果队列满,则阻塞 take:移除并返回队列头部的元素
借鉴:https://blog.csdn.net/u012050154/article/details/60572567 https://www.cnblogs.com/lemon-flm/p/7877898.html https://blog.csdn.net/qq_33524158/article/details/78578370