JAVA队列及实现类

news2024/11/15 12:02:26

什么是队列?

      队列是一种特殊的线性表,遵循先入先出、后入后出的基本原则,一般来说,它只允许在表的前端进行删除操作,而在表的后端进行插入操作,但是java的某些队列运行在任何地方插入删除;比如我们常用的 LinkedList 集合,它实现了Queue 接口,因此,我们可以理解为 LinkedList 就是一个队列;

java队列特性

队列主要分为阻塞和非阻塞,有界和无界、单向链表和双向链表之分;

阻塞和非阻塞

阻塞队列
          入列(添加元素)时,如果元素数量超过队列总数,会进行等待(阻塞),待队列的中的元素出列后,元素数量未超过队列总数时,就会解除阻塞状态,进而可以继续入列;
          出列(删除元素)时,如果队列为空的情况下,也会进行等待(阻塞),待队列有值的时候即会解除阻塞状态,进而继续出列;
          阻塞队列的好处是可以防止队列容器溢出;只要满了就会进行阻塞等待;也就不存在溢出的情况;
          只要是阻塞队列,都是线程安全的;
          

非阻塞队列
          不管出列还是入列,都不会进行阻塞,
          入列时,如果元素数量超过队列总数,则会抛出异常,
          出列时,如果队列为空,则取出空值;

一般情况下,非阻塞式队列使用的比较少,一般都用阻塞式的对象比较多;阻塞和非阻塞队列在使用上的最大区别就是阻塞队列提供了以下2个方法:

  •     出队阻塞方法 : take()
  •     入队阻塞方法 : put()

有界和无界

    有界:有界限,大小长度受限制
    无界:无限大小,其实说是无限大小,其实是有界限的,只不过超过界限时就会进行扩容,就行ArrayList 一样,在内部动态扩容
   

单向链表和双向链表

单向链表 : 每个元素中除了元素本身之外,还存储一个指针,这个指针指向下一个元素;

双向链表 :除了元素本身之外,还有两个指针,一个指针指向前一个元素的地址,另一个指针指向后一个元素的地址;

Java 队列接口继承图

队列常用方法

  add        增加一个元索                     如果队列已满,则抛出一个IIIegaISlabEepeplian异常
  remove   移除并返回队列头部的元素    如果队列为空,则抛出一个NoSuchElementException异常
  element  返回队列头部的元素             如果队列为空,则抛出一个NoSuchElementException异常
  offer       添加一个元素并返回true       如果队列已满,则返回false
  poll         移除并返问队列头部的元素    如果队列为空,则返回null
  peek       返回队列头部的元素             如果队列为空,则返回null
  put         添加一个元素                      如果队列满,则阻塞
  take        移除并返回队列头部的元素     如果队列为空,则阻塞
       drainTo(list)   一次性取出队列所有元素

知识点: remove、element、offer 、poll、peek 其实是属于Queue接口。 

非阻塞队列:

1、ConcurrentLinkedQueue

  单向链表结构的无界并发队列, 非阻塞队列,由CAS实现线程安全,内部基于节点实现

2、ConcurrentLinkedDeque  

双向链表结构的无界并发队列, 非阻塞队列,由CAS实现线程安全    

3、PriorityQueue

内部基于数组实现,线程不安全的队列

 

阻塞队列:

1、DelayQueue

一个支持延时获取元素的无界阻塞队列

2、LinkedTransferQueue

一个由链表结构组成的无界阻塞队列。

Java并发包--LinkedBlockingDeque - ken007 - 博客园

3、ArrayBlockingQueue

有界队列,阻塞式,初始化时必须指定队列大小,且不可改变;,底层由数组实现;

4、SynchronousQueue

最多只能存储一个元素,每一个put操作必须等待一个take操作,否则不能继续添加元素

5、PriorityBlockingQueue

一个带优先级的队列,而不是先进先出队列。元素按优先级顺序被移除,而且它也是无界的,也就是没有容量上限,虽然此队列逻辑上是无界的,但是由于资源被耗尽,所以试图执行添加操作可能会导致 OutOfMemoryError 错误;

重点博客:

        LinkedBlockingDeque:一个由链表结构组成的双向阻塞队列。(LinkedBlockingDeque还是可选容量的(防止过度膨胀),即可以指定队列的容量。如果不指定,默认容量大小等于Integer.MAX_VALUE(@Native public static final int MAX_VALUE = 0x7fffffff))

  ArrayBlockingQueue:一个由数组结构组成的有界阻塞队列。 

  LinkedBlockingQueue:一个由链表结构组成的有界阻塞队列。 

  PriorityBlockingQueue:一个支持优先级排序的无界阻塞队列。 

  LinkedTransferQueue:一个由链表结构组成的无界阻塞队列。 

  SynchronousQueue:一个不存储元素的阻塞队列。 

  DealyQueue:一个使用优先级队列实现的无界阻塞队列。 

高并发第十三弹:J.U.C 队列 SynchronousQueue.ArrayBlockingQueue.LinkedBlockingQueue.LinkedTransferQueue - 爱呼吸的鱼 - 博客园

双端队列:

双端队列既可以当作队列也可以当作栈!方法中可以先入先出也可以先入后出,因为是双端的,所以栈我们不推荐使用Vector的实现类Stack,推荐使用双端队列ArrayDeque来做栈。

Deque———ArrayDeque类详解

  • 类型方法作用
    添加元素public void addFirst(E e)在数组前面添加元素
    public void addLast(E e)在数组后面添加元素
    public boolean offerFirst(E e)在数组前面添加元素,并返回是否添加成功
    public boolean offerLast在数组后面添加元素,并返回是否添加成功
    删除元素public E pollFirst()删除第一个元素,并返回删除元素的值,如果元素为null,将返回null
    public E removeFirst()删除第一个元素,并返回删除元素的值,如果元素为null,将抛出异常
    public E pollLast()删除最后一个元素,并返回删除元素的值,如果为null,将返回null
    public E removeLast()删除最后一个元素,并返回删除元素的值,如果为null,将抛出异常
    public boolean removeFirstOccurrence(Object o)删除第一次出现的指定元素
    public boolean removeLastOccurrence(Object o)删除最后一次出现的指定元素
    获取元素public E getFirst()获取第一个元素,如果没有将抛出异常
    public E getLast()获取最后一个元素,如果没有将抛出异常
    队列操作public boolean add(E e)在队列尾部添加一个元素
    public boolean offer(E e)在队列尾部添加一个元素,并返回是否成功
    public E remove()删除队列中第一个元素,并返回该元素的值,如果元素为null,将抛出异常(其实底层调用的是removeFirst())
    public E poll()删除队列中第一个元素,并返回该元素的值,如果元素为null,将返回null(其实调用的是pollFirst())
    public E element()获取第一个元素,如果没有将抛出异常
    public E peek()获取第一个元素,如果返回null
    栈操作public void push(E e)栈顶添加一个元素
    public E pop()移除栈顶元素,如果栈顶没有元素将抛出异常
    其他public int size()获取队列中元素个数
    public boolean isEmpty()判断队列是否为空
    public Iterator iterator()迭代器,从前向后迭代
    public Iterator descendingIterator()迭代器,从后向前迭代
    public boolean contains(Object o)判断队列中是否存在该元素
    public Object[] toArray()转成数组
    public T[] toArray(T[] a)转成a数组常
    public void clear()清空队列
    public ArrayDeque clone()克隆(复制)一个新的队列
  • 六.参考资料

一.数据结构

ArrayDeque类是 双端队列的线性实现类。

具有以下特征:

☞ ArrayDeque是采用数组方式实现的双端队列。
☞ ArrayDeque的出队入队是通过头尾指针循环,利用数组实现的。
☞ ArrayDeque容量不足时是会扩容的,每次扩容容量增加一倍。
☞ ArrayDeque可以直接作为栈使用。当用作栈时,性能优于Stack,当用于队列时,性能优于LinkedList。
☞ 无容量大小限制,容量按需增长。
☞ 非线程安全队列,无同步策略,不支持多线程安全访问。
☞ 具有fail-fast特性,不能存储null值,支持双向迭代器遍历。

ArrayDeque的实现结构图如下所示:


二.类标题

ArrayDeque类的标题如下:

public class ArrayDeque extends AbstractCollection implements Deque, Cloneable, Serializable

这个标题说明ArrayDeque类是AbstractCollection类的子类,并且实现了三个接口:Deque、Cloneable和Serializable。

如下图所示:

1.ArrayDeque实现了Deque接口,即能将LinkedList当做双端队列使用。
2.ArrayDeque实现了Cloneable接口,即覆盖了函数clone(),能克隆。
3.ArrayDeque实现java.io.Serializable接口,LinkedList支持序列化,能通过序列化去传输。
4.ArrayDeque是非同步的[2]。

【注2】在这里的非同步指的是,当使用线程的时候,对于这个集合对象进行操作,那么不同的线程所获取的这个集合对象是不同的.所以是说不同步,在多线程的形式是不安全的.


三.字段

transient Object[] elements;
存储元素的数组

transient int head;
队列头位置

transient int tail;
队列尾位置

private static final int MIN_INITIAL_CAPACITY = 8;
一个新创建的队列的最小容量


四.构造函数

4.1 无参的构造方法,创建一个容量为16的ArrayDeque

源码如下:

 
  1. public ArrayDeque() { //无参构造函数,默认的底层数组大小为16.

  2. elements = new Object[16];

  3. }

4.2 有参的构造方法,创建一个指定大小的ArrayDeque

源码如下:

 
  1. public ArrayDeque(int numElements) { //如果指定初始容量小于8,将会返回容量为8的新数组。

  2. allocateElements(numElements); //调用allocateElements方法,分配新数组

  3. }

  4. private void allocateElements(int numElements) {

  5. int initialCapacity = MIN_INITIAL_CAPACITY;

  6. //做移位与运算最后加一得到比给定长度大的最小的2的幂数。

  7. if (numElements >= initialCapacity) {

  8. initialCapacity = numElements;

  9. initialCapacity |= (initialCapacity >>> 1);

  10. initialCapacity |= (initialCapacity >>> 2);

  11. initialCapacity |= (initialCapacity >>> 4);

  12. initialCapacity |= (initialCapacity >>> 8);

  13. initialCapacity |= (initialCapacity >>> 16);

  14. initialCapacity++;

  15. if (initialCapacity < 0) // Too many elements, must back off

  16. initialCapacity >>>= 1;// Good luck allocating 2 ^ 30 elements

  17. }

  18. elements = new Object[initialCapacity];

  19. }

源码分析:对于一个给定长度,先判断是否小于定义的最小长度,如果小于,则使用定义的最小长度作为数组的长度。否则,找到比给定长度大的最小的2的幂数(在if里面的语句实现这一功能)。

如下图所示:

【注】 ">>>"表示无符号右移,也叫逻辑右移。即若该数为正,则高位补0,若该数为负数,则右移后高位同样补0.

4.3 有参的构造方法,将现有集合元素C加入队列进行构造

源码如下:

 
  1. public ArrayDeque(Collection<? extends E> c) {

  2. allocateElements(c.size());//调用上述allocateElements()方法,分配型数组内存空间。

  3. addAll(c);//调用addAll()方法,将现有集合元素c添加到ArrayDeque中。

  4. }

  5. //addAll(Collection c) inherited from AbstractCollection

  6. public boolean addAll(Collection<? extends E> c) {

  7. boolean modified = false;

  8. for (E e : c)

  9. if (add(e))

  10. modified = true;

  11. return modified;

  12. }

  13. //将集合元素添加到ArrayDeque末尾

  14. public boolean add(E e) {

  15. addLast(e);//addLast()方法作用为:在最后一个元素后面添加元素。详见下述public void addLast(E e)。

  16. return true;

  17. }

源码分析: 先根据已有集合c大小,通过allocateElement()方法创建最小的2的幂数的数组空间。addAll()将c中元素通过add()逐个添加到型数组中。


五.方法分析

添加元素

public void addFirst(E e)
作用:在ArrayDeque前面添加元素。

源码如下:

 
  1. public void addFirst(E e) {

  2. if (e == null)

  3. throw new NullPointerException();

  4. elements[head = (head - 1) & (elements.length - 1)] = e;//将元素e添加到ArrayDeque双端队列的队首位置。

  5. if (head == tail)//(head == tail)判定内存不足

  6. doubleCapacity();//进行扩容操作

  7. }

  8. //扩容为原来的两倍

  9. private void doubleCapacity() {

  10. assert head == tail;

  11. int p = head;

  12. int n = elements.length;

  13. int r = n - p; // number of elements to the right of p

  14. int newCapacity = n << 1;

  15. if (newCapacity < 0)

  16. throw new IllegalStateException("Sorry, deque too big");

  17. Object[] a = new Object[newCapacity];

  18. System.arraycopy(elements, p, a, 0, r);

  19. System.arraycopy(elements, 0, a, r, p);

  20. elements = a;

  21. head = 0;

  22. tail = n;

  23. }

  24. //java.lang.System

  25. /*

  26. @Function:复制数组,以插入元素,但是要将index之后的元素都往后移一位。然后就是插入元素,增加sized的值

  27. @src:源数组 srcPos:源数组要复制的起始位置 dest:目的数组 destPos:目的数组放置的起始位置 length:复制的长度

  28. */

  29. public static native void arraycopy(Object src,int srcPos,Object dest, int destPosint length);

源码分析:将元素插入到head前一位,同时修改head值。判断内存是否足够,若不够,扩容为原数组的两倍。然后通过System.arraycopy(),将原来数组的元素复制到新数组中。

elements[head = (head - 1) & (elements.length - 1)] = e;

当head ≠ 0时

因为element数组的内存大小为2的n次幂,因此(elements.length-1),二进制为全1,[head - 1] & (elements.length - 1)]值始终为head-1的值。即在element[head-1]插入元素。

当head = 0时

head - 1 = -1。其中-1用二进制表示为全1,与elements.length - 1逐位与,结果为elements.length - 1的值,即在数组的末尾插入元素。

System.arraycopy(elements, p, a, 0, r);
System.arraycopy(elements, 0, a, r, p);

将elements数组从head索引(n-p)长度复制到a数组从0开始的位置。然后将elements数组从0索引开始p长度复制到a数组r索引开始的位置。

如下图所示:


public void addLast(E e)
作用:在ArrayDeque后面添加元素。

源码如下:

 
  1. public void addLast(E e) {

  2. if (e == null)

  3. throw new NullPointerException();

  4. elements[tail] = e;//将e放到tail位置

  5. if ( (tail = (tail + 1) & (elements.length - 1)) == head)//和head的操作类似,为了处理临界情况 (tail为length - 1时),和length - 1进行与操作,结果为0

  6. doubleCapacity();//将ArrayDeque容量扩展为原来的两倍。源码详见上述public void addFirst(E e)

  7. }

源码分析: 在ArrayDeque中tail索引处添加元素e。若添加元素后tail+1 == head,判定内存不足,对ArrayDeque调用doubleCapacity()进行扩容操作。


public boolean offerFirst(E e)
作用:在ArrayDeque前添加一个元素,并返回是否添加成功。

源码如下:

 
  1. public boolean offerFirst(E e) {

  2. addFirst(e);//在ArrayDeque数组head前添加元素,addFirst()详见上述public void addFirst().

  3. return true;

  4. }

源码分析: 调用addFirst()方法,当添加成功后返回true。


public boolean offerLast(Object o)
作用:在ArrayDeque后面添加一个元素,并返回是否添加成功。

源码如下:

 
  1. public boolean offerLast(E e) {

  2. addLast(e);//在ArrayDeque数组tail出添加元素,addLast()详见上述public void addLast()

  3. return true;

  4. }

源码分析: 调用addLast()方法,当添加成功后返回true.


public E pollFirst()
作用:删除第一个元素,并返回删除元素的值。如果元素为null,将返回null.

源码如下:

 
  1. public E pollFirst() {

  2. int h = head;

  3. @SuppressWarnings("unchecked")

  4. E result = (E) elements[h];

  5. // Element is null if deque empty

  6. if (result == null)

  7. return null;

  8. elements[h] = null; // Must null out slot

  9. head = (h + 1) & (elements.length - 1);

  10. return result;

  11. }

源码分析: 将数组的第一个元素赋值给result并返回,同时将head后移。


public E removeFirst()
作用:删除第一个元素,并返回删除元素的值。如果元素为null,将抛出异常。

源码如下:

 
  1. public E removeFirst() {

  2. E x = pollFirst();//将删除后的值赋给x,pollFirst()详见上述pollFirst()

  3. if (x == null)

  4. throw new NoSuchElementException();

  5. return x;

  6. }

源码分析: 调用pollFirst()返回删除的值,若返回值为null,抛出异常。


public E pollLast()
作用:删除最后一个元素,并返回删除元素的值。如果元素为null,将返回null。

源码如下:

 
  1. public E pollLast() {

  2. int t = (tail - 1) & (elements.length - 1);

  3. @SuppressWarnings("unchecked")

  4. E result = (E) elements[t];

  5. if (result == null)

  6. return null;

  7. elements[t] = null;

  8. tail = t;

  9. return result;

  10. }

源码分析: (tail - 1) & (elements.length - 1)指定待删除元素的位置,并将待删除元素赋值给result.同时将数组中最后一个元素赋null值。


public E removeLast()
作用:删除最后一个元素,并返回删除元素的值。如果元素为null,将抛出异常。

源码如下:

 
  1. public E removeLast() {

  2. E x = pollLast();

  3. if (x == null)

  4. throw new NoSuchElementException();

  5. return x;

  6. }

源码分析: 调用pollLast()返回删除的值,若返回值为null,抛出异常。


public boolean removeFirstOccurrence(Object o)
作用:删除第一次出现的指定元素。

源码如下:

 
  1. public boolean removeFirstOccurrence(Object o) {

  2. if (o == null)

  3. return false;

  4. int mask = elements.length - 1;

  5. int i = head;

  6. Object x;

  7. while ( (x = elements[i]) != null) {

  8. if (o.equals(x)) {

  9. delete(i);

  10. return true;

  11. }

  12. i = (i + 1) & mask;//从头到尾遍历

  13. }

  14. return false;

  15. }

源码分析:

i = (i + 1) & mask;

对数组从头到尾进行遍历,

原理如下图所示:

从数组的head处对非空元素进行遍历,若数组中包含o对象,调用delete()进行删除,并返回true;否则,返回false。

private boolean delete(int i)源码如下所示:

 
  1. private void checkInvariants() {//有效性检查

  2. assert elements[tail] == null;//tail位置没有元素

  3. assert head == tail ? elements[head] == null :

  4. (elements[head] != null &&

  5. elements[(tail - 1) & (elements.length - 1)] != null);//如果head和tail重叠,队列为空;否则heaed位置有元素,tail-1位置有元素

  6. assert elements[(head - 1) & (elements.length - 1)] == null;//head-1 的位置没有元素

  7. }

  8. private boolean delete(int i) {

  9. checkInvariants();

  10. final Object[] elements = this.elements;

  11. final int mask = elements.length - 1;

  12. final int h = head;

  13. final int t = tail;

  14. final int front = (i - h) & mask;//i到head元素处之间的元素个数

  15. final int back = (t - i) & mask;//i到tail元素处之间的元素个数

  16. // Invariant: head <= i < tail mod circularity

  17. if (front >= ((t - h) & mask))//i到head元素处的距离大于现有元素总数,抛出异常

  18. throw new ConcurrentModificationException();

  19. // Optimize for least element motion

  20. if (front < back) {//i的元素靠近head,移动开始的元素,返回false.

  21. if (h <= i) {//当i在head的后面

  22. //将从head开始长度为front的数组片段复制到head+1开始的地方

  23. System.arraycopy(elements, h, elements, h + 1, front);

  24. } else { // 当i在head的前面

  25. //将0 ~ (i - 1)的元素后移一位,将数组最后一位元素移到数组第一位,将head后的元素后移一位。

  26. System.arraycopy(elements, 0, elements, 1, i);

  27. elements[0] = elements[mask];

  28. System.arraycopy(elements, h, elements, h + 1, mask - h);

  29. }

  30. elements[h] = null;

  31. head = (h + 1) & mask;

  32. return false;

  33. } else {//i的位置靠近tail,移动末尾的元素,返回true.

  34. if (i < t) { 当i在tail的前面

  35. //将从i + 1开始长度为back的数组片段复制到以i开始的地方

  36. System.arraycopy(elements, i + 1, elements, i, back);

  37. tail = t - 1;

  38. } else { //当i在tail后面

  39. //将从i+1到数组最后一个元素往前移动一位,再将第一个元素移到最后一位。将剩余元素往前移动一位

  40. System.arraycopy(elements, i + 1, elements, i, mask - i);

  41. elements[mask] = elements[0];

  42. System.arraycopy(elements, 1, elements, 0, t);

  43. tail = (t - 1) & mask;

  44. }

  45. return true;

  46. }

  47. }

源码分析: 为了算法的复杂度,将delete()函数分为三种情况

如下图所示:

一.待删除元素距离第一个元素比最后一个元素近

1.1 待删除元素在数组中的位置在第一个元素的后面

将从head开始长度为front的数组片段复制到head+1开始的地方。如下图所示:

1.2 待删除元素在数组中的位置在第一个元素的前面

将0 ~ (i - 1)的元素后移一位,将数组最后一位元素移到数组第一位,将head后的元素后移一位。如下图所示:

二.待删除元素距离最后一个元素比第一个元素近

2.1 待删除元素在数组中的位置在第一个元素的前面

将从i + 1开始长度为back的数组片段复制到以i开始的地方。如下图所示:

2.2 待删除元素在数组中的位置在第一个元素的后面

将从i+1到数组最后一个元素往前移动一位,再将第一个元素移到最后一位。将剩余元素往前移动一位。如下图所示:

三.待删除元素到第一个元素的距离等于到最后一个元素的距离

同情况二。


public boolean removeLastOccurrence(Object o)
作用:删除最后一次出现的指定元素。

源码如下:

 
  1. public boolean removeLastOccurrence(Object o) {

  2. if (o == null)

  3. return false;

  4. int mask = elements.length - 1;

  5. int i = (tail - 1) & mask;

  6. Object x;

  7. while ( (x = elements[i]) != null) {

  8. if (o.equals(x)) {

  9. delete(i);

  10. return true;

  11. }

  12. i = (i - 1) & mask;//从尾到头遍历

  13. }

  14. return false;

  15. }

源码分析: 从最后一个元素处对数组进行遍历,若数组中包含o对象,调用delete()进行删除,并返回true;否则,返回false。原理同上述public boolean removeFirstOccurrence(Object o)。


public E getFirst()
作用:获取第一个元素,如果没有将抛出异常。

源码如下:

 
  1. public E getFirst() {

  2. @SuppressWarnings("unchecked")

  3. E result = (E) elements[head];

  4. if (result == null)

  5. throw new NoSuchElementException();

  6. return result;

  7. }

源码分析: 将head索引处元素值返回。


public E getLast()
作用:获取最后一个元素,如果没有将抛出异常。

源码如下:

 
  1. public E getLast() {

  2. @SuppressWarnings("unchecked")

  3. E result = (E) elements[(tail - 1) & (elements.length - 1)];

  4. if (result == null)

  5. throw new NoSuchElementException();

  6. return result;

  7. }

源码分析: 将最后一个元素值返回。


public boolean add(E e)
作用:在队列尾部添加一个元素。

源码如下:

 
  1. public boolean add(E e) {

  2. addLast(e);//addLast()方法作用为:在最后一个元素后面添加元素。详见下述public void addLast(E e)。

  3. return true;

  4. }


public boolean offer(E e)
作用:在队列尾部添加一个元素,并返回是否成功

源码如下:

 
  1. public boolean offer(E e) {

  2. return offerLast(e);//offerLast()源码分析详见上述public boolean offerLast(Object o)

  3. }


public E remove()
作用:删除队列中第一个元素,并返回该元素的值,如果元素为null,将抛出异常(其实底层调用的是removeFirst())

源码如下:

 
  1. public E remove() {

  2. return removeFirst();//移除队列第一个元素。removeFirst()源码分析详见上述:public E removeFirst()

  3. }


public E poll()
作用:删除队列中第一个元素,并返回该元素的值,如果元素为null,将返回null。

源码如下:

 
  1. public E poll() {

  2. return pollFirst();//删除第一个元素,并返回删除元素的值.pollFirst()源码分析详见上述public E pollFirst()

  3. }


public E element()
作用:获取第一个元素。如果没有将抛出异常

源码如下:

 
  1. public E element() {

  2. return getFirst();//getFirst()用于获取第一个元素, 源码详见上述: public E getFirst()

  3. }


public E peek()
作用:获取第一个元素,如果返回null.

源码如下:

 
  1. public E peek() {

  2. return peekFirst();

  3. }

  4. public E peekFirst() {

  5. // elements[head] is null if deque empty

  6. return (E) elements[head];

  7. }


public void push(E e)
作用:栈顶添加一个元素.

源码如下:

 
  1. public void push(E e) {

  2. addFirst(e);//在head索引前添加元素,并将head前移。源码分析详见上述:public void addFirst(E e)

  3. }


public E pop()
作用:栈顶添加一个元素.

源码如下:

 
  1. public E pop() {

  2. return removeFirst();//删除第一个元素,并返回删除元素的值。源码分析详见上述:public E removeFirst()

  3. }


public int size()
作用:获取队列中元素个数.

源码如下:

 
  1. public int size() {

  2. return (tail - head) & (elements.length - 1);

  3. }

源码分析: 当tail在数组中的位置在head的后面(tail - head) & (elements.length - 1) 等价于 (tail - head)。当tail在数组中的位置在head的前面(tail - head) & (elements.length - 1) 等价于 elements - (tail - head)。


public boolean isEmpty()
作用:判断队列是否为空。

源码如下:

 
  1. public boolean isEmpty() {

  2. return head == tail;

  3. }

源码分析: tail位置的元素一定为空,head和tail相等,也为空。


public Iterator iterator()
作用:迭代器,从前往后迭代

源码如下:

 
  1. public Iterator<E> iterator() {

  2. return new DeqIterator();

  3. }

  4. private class DeqIterator implements Iterator<E> {

  5. private int cursor = head;

  6. private int fence = tail; // 迭代终止索引,同时也为了检测并发修改。

  7. private int lastRet = -1; // 最近的next()调用返回的索引。据此可以定位到需要删除元素的位置。

  8. public boolean hasNext() {

  9. return cursor != fence;

  10. }

  11. public E next() {

  12. if (cursor == fence)

  13. throw new NoSuchElementException();

  14. E result = elements[cursor];

  15. // This check doesn't catch all possible comodifications,

  16. // but does catch the ones that corrupt traversal

  17. if (tail != fence || result == null)

  18. throw new ConcurrentModificationException();

  19. lastRet = cursor;

  20. cursor = (cursor + 1) & (elements.length - 1); // 游标位置加1

  21. return result;

  22. }

  23. public void remove() {

  24. if (lastRet < 0)

  25. throw new IllegalStateException();

  26. if (delete(lastRet)) { // 如果将元素从右往左移,需要将游标减1。

  27. cursor = (cursor - 1) & (elements.length - 1); // 游标位置回退1。

  28. fence = tail; // 重置阀值。

  29. }

  30. lastRet = -1;

  31. }

  32. }

源码分析: ArrayDeque继承了Iterable接口,必须实现其中的iterator(),ArrayDeque实现从头往后遍历的迭代器iterator(),其中主要包含:hasNext()方法用于判定当前cursor是否还有下一个元素;next()方法来锁定下一个元素;以及remove()用于移除lastRet处的元素值。


public Iterator descendingIterator()
作用:迭代器,从后向前迭代

源码如下:

 
  1. public Iterator<E> descendingIterator() {

  2. return new DescendingIterator();

  3. }

  4. private class DescendingIterator implements Iterator<E> {

  5. private int cursor = tail; // 游标开始索引为tail

  6. private int fence = head; // 游标的阀值为head

  7. private int lastRet = -1;

  8. public boolean hasNext() {

  9. return cursor != fence;

  10. }

  11. public E next() {

  12. if (cursor == fence)

  13. throw new NoSuchElementException();

  14. cursor = (cursor - 1) & (elements.length - 1); // tail是下个添加元素的位置,所以要减1才是尾节点的索引。

  15. E result = elements[cursor];

  16. if (head != fence || result == null)

  17. throw new ConcurrentModificationException();

  18. lastRet = cursor;

  19. return result;

  20. }

  21. public void remove() {

  22. if (lastRet < 0)

  23. throw new IllegalStateException();

  24. if (!delete(lastRet)) { // 如果从左往右移,需要将游标加1。

  25. cursor = (cursor + 1) & (elements.length - 1);

  26. fence = head;

  27. }

  28. lastRet = -1;

  29. }

  30. }

源码分析: DescendingIterator是从后往前的迭代器。其中主要包含:hasNext()方法用于判定当前cursor是否还有下一个元素;next()方法来锁定下一个元素;以及remove()用于移除lastRet处的元素值。


public boolean contains(Object o)
作用:判断队列中是否存在钙元素。

源码如下:

 
  1. public boolean contains(Object o) {

  2. if (o == null)

  3. return false;//ArrayDeque不能存储null值

  4. int mask = elements.length - 1;

  5. int i = head;

  6. Object x;

  7. while ( (x = elements[i]) != null) {

  8. if (o.equals(x))

  9. return true;

  10. i = (i + 1) & mask;//处理临界情况

  11. }

  12. return false;

  13. }

源码分析: 同上述:public boolean removeFirstOccurrence(Object o),从前往后遍历,如果在数组中存在与o相同的元素,则返回true。否则,返回false。


public Object[] toArray()
作用:转成数组。

源码如下:

 
  1. public Object[] toArray() {

  2. return copyElements(new Object[size()]);

  3. }

  4. private <T> T[] copyElements(T[] a) {

  5. if (head < tail) {//将elements数组所有元素复制到从0索引开始的a数组中

  6. System.arraycopy(elements, head, a, 0, size());

  7. } else if (head > tail) {//先复制从elements数组head~elements.length - 1处数组,然后将0 ~ tail - 1索引处元素复制到后面

  8. int headPortionLen = elements.length - head;

  9. System.arraycopy(elements, head, a, 0, headPortionLen);

  10. System.arraycopy(elements, 0, a, headPortionLen, tail);

  11. }

  12. return a;

  13. }

源码分析: 把所有元素拷贝到新创建的Object数组上,所以对返回数组的修改不会影响该双端队列。


public T[] toArray(T[] a)
作用:转成指定数组。

源码如下:

 
  1. public <T> T[] toArray(T[] a) {

  2. int size = size();

  3. if (a.length < size)//目标数组大小不够

  4. a = (T[])java.lang.reflect.Array.newInstance(

  5. a.getClass().getComponentType(), size);//利用反射创建类型为T,大小为size的数组

  6. copyElements(a);//拷贝所有元素到目标数组。源码详见上述:>public Object[] toArray()

  7. if (a.length > size)

  8. a[size] = null;//结束标识

  9. return a;

  10. }

源码分析:

a = (T[])java.lang.reflect.Array.newInstance(a.getClass().getComponentType(), size);


public void clear()
作用:清空队列。

源码如下:

 
  1. public void clear() {

  2. int h = head;

  3. int t = tail;

  4. if (h != t) { // 判空条件

  5. head = tail = 0;

  6. int i = h;

  7. int mask = elements.length - 1;

  8. do {

  9. elements[i] = null;//清除元素

  10. i = (i + 1) & mask;

  11. } while (i != t);

  12. }

  13. }

源码分析: 从前往后将数组值置空值。

public ArrayDeque clone()
作用:克隆(复制)一个新的队列。

源码如下:

 
  1. public ArrayDeque<E> clone() {

  2. try {

  3. @SuppressWarnings("unchecked")

  4. ArrayDeque<E> result = (ArrayDeque<E>) super.clone();

  5. //传入elements数组与数组长度返回一个新数组。

  6. result.elements = Arrays.copyOf(elements, elements.length);//深度复制

  7. return result;

  8. } catch (CloneNotSupportedException e) {

  9. throw new AssertionError();

  10. }

  11. }

源码分析: ArrayDeque类实现了Cloneable接口,可以通过super调用父类Object的clone(),克隆后result指向ArrayDeque队列。


六.参考资料

死磕 java集合之ArrayDeque源码分析
ArrayDeque类的使用详解

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/64716.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

常用网络接口自动化测试框架应用

一、RESTful&#xff08;resource representational state transfer)类型接口测试 (一&#xff09;GUI界面测试工具&#xff1a;jmeter 1、添加线程组 2、添加http请求 3、为线程组添加察看结果树 4、写入接口参数并运行 5、在查看结果树窗口查看结果 6、多组数据可增加CSVDat…

git原理浅析

1.git概念 我们的项目一般由文件夹和文件组成&#xff0c;在文件系统中,基本都是树形结构, 在git中&#xff0c;文件夹称为 “tree” &#xff0c;文件称为 “blob” &#xff0c;顶层文件夹称为 “top-level tree” 。下方的目录结构是个例子而已&#xff1a; . (top-level t…

Global Mapper栅格计算器,波段计算NDVI、NDSI、NDWI等

Global Mapper栅格计算器&#xff0c;波段计算NDVI、NDSI、NDWI等1. Global Mapper中的栅格计算器2. 查看数据属性&#xff0c;检查波段数量3. 打开栅格计算器&#xff0c;进行波段计算Global Mapper功能丰富&#xff0c;其栅格计算器工具内置很多遥感指数&#xff0c;方便进行…

TwineCompile高级编译系统

TwineCompile高级编译系统 TwineCompile是我们对C编译速度慢的解决方案。通过使用多线程、文档缓存和自动化后台编译技术&#xff0c;集成到CBuilder IDE中&#xff0c;大大降低了编译/制作/构建的次数。 TwineCompile是一个创新的电子书系统&#xff0c;它利用多线程工程和缓存…

Java项目:SSM学生选课管理系统

作者主页&#xff1a;源码空间站2022 简介&#xff1a;Java领域优质创作者、Java项目、学习资料、技术互助 文末获取源码 项目介绍 由SpringMVCMyBatis为主要框架&#xff0c;mysql8.0配置主从复制实现读写分离。前端主要由bootstrap完成&#xff0c;背景用particles.js插件。…

Spring Boot整合JWT实现用户认证

初探JWT 什么是JWT JWT(Json Web Token)&#xff0c;是一种工具&#xff0c;格式为XXXX.XXXX.XXXX的字符串&#xff0c;JWT以一种安全的方式在用户和服务器之间传递存放在JWT中的不敏感信息。 为什么要用JWT 设想这样一个场景&#xff0c;在我们登录一个网站之后&#xff0…

[Cortex-M3]-2-map文件解析

目录 1 几个问题 1.1 什么是map文件 1.2 如何查看编译出的程序和数据的信息 1.3 如何生成map文件 1.4 map文件里面有哪些信息 2 map文件信息详解 2.1 Section Cross References 2.2 Removing Unused input…

15年磨一剑,亚马逊云科技数据产品掌门人 Swami 揭秘云原生数据战略的三大关键要素

2022亚马逊云科技 re:Invent 全球大会正在拉斯维加斯如火如荼进行中&#xff0c;亚马逊云科技数据与机器学习副总裁 Swami Sivasubramanian 博士发表了“数据与机器学习如何助力企业构建端到端的数据战略”的主题演讲来开启第三天的日程。 Swami 博士重点介绍了亚马逊云科技在…

玉米脱粒机设计全套

目 录 摘要 I Abstract II 1引言 1 1.1 课题的来源与研究的目的和意义 1 1.2 本课题研究的内容 3 2玉米脱粒机总体结构的设计 5 2.1 玉米脱粒机工作方式的选择 7 2.2 玉米脱粒机的结构原理 10 2.3 机械传动部分的设计计算 11 2.3.1电机的选型计算 12 2.3.2 V带传动的设计计算 1…

C语言:文件操作(2)

文件的打开和关闭 文件在读写之前应该先打开文件&#xff0c;在使用结束之后应该关闭文件。 在编写程序的时候&#xff0c;在打开文件的同时&#xff0c;都会返回一个FILE*的指针变量指向该文件&#xff0c;也相当于建立了指针和文件的关系。 ANSIC规定使用fopen函数来打开文…

(十五) 共享模型之工具【线程池】

一、自定义线程池 1. 简易线程池 Slf4j(topic "c.TestPool") public class TestPool {public static void main(String[] args) {ThreadPool threadPool new ThreadPool(2,1000, TimeUnit.MILLISECONDS, 10);for (int i 0; i < 5; i) {int j i;threadPool.exe…

博球一看,记录疯狂!我与世界杯的那些二三事

文章目录 &#x1f525;关于世界杯 &#x1f525;关于2022卡塔尔世界杯 &#x1f525;我与足球 &#x1f525;我与世界杯 ⚽分享一颗足球 ⚽实现效果 &#x1f525;关于世界杯 大力神杯 国际足联世界杯&#xff08;FIFA World Cup&#xff09;&#xff0c;简称“世界杯”…

Vue中的数据代理与数据劫持

数据代理 数据代理字面上是通过一个对象代理对另一个对象属性的操作在vue中的数据代理&#xff0c;实际上是通过vm上的属性代理对_data中属性的操作 数据劫持 数据劫持也可称作数据代理&#xff0c;字面上是劫持到某个属性的变化&#xff0c;去做其他的操作在vue中的数据劫…

练习:查询学生新学期选课(python之str、dict、list试炼)

查询学生新学期选课(python之str、dict、list试炼)&#xff0c;数据用字典、列表存储。考验字符串的各种转换&#xff0c;字典、列表的读写。 (本文获得CSDN质量评分【88】)【学习的细节是欢悦的历程】Python 官网&#xff1a;https://www.python.org/ Free&#xff1a;大咖免…

【Git 教程系列第 26 篇】Mac 升级系统到 Ventura 后,Git 公钥报 Permission denied 错误问题的解决方案

这是【Git 教程系列第 26 篇】&#xff0c;如果觉得有用的话&#xff0c;欢迎关注专栏。 注&#xff1a; 如果你是因为升级系统到 Ventura 后遇到的这个问题&#xff0c;可以直接看第三步的解决方案&#xff0c;前两步是我自己的写作习惯&#xff0c;只是记录一下这个过程&…

Qt OpenGL 图形字体的纹理映射

这次教程中&#xff0c;我们将在第14课的基础上创建带有纹理的字体&#xff0c;它真的很简单。也许你想知道如何才能给字体赋予纹理贴图&#xff1f;我们可以使用自动纹理坐标生成器&#xff0c;它会自动为字体上的每一个多边形生成纹理坐标。 这次课中我们还将使用Wingdings字…

BNext

又搬来了大神器啊 来自德国HassoPlattner计算机系统工程研究院的NianhuiGuo和HaojinYang等研究者提出了BNext模型&#xff0c;成为第一个在ImageNet数据集上top1分类准确率突破80%的BNN。 两年前&#xff0c;依靠早期 BNN 工作 XNOR-Net 起家的 XNOR.AI 被苹果公司收购&#…

redis基础5——redis的频道订阅和模式频道、redis主从复制、哨兵集群

文章目录一、发布订阅1.1 发布订阅过程1.2 发布订阅类型1.2.1 频道的发布订阅1.2.1.1 订阅频道* 实现原理1.2.1.2 发送消息* 实现原理1.2.1.3 退订频道* 实现原理1.2.2 模式的发布订阅1.2.2.1 订阅模式频道* 实现原理1.2.2.2 查询订阅与发布系统状态1.2.2.3 发送消息* 实现原理…

【c++基础】第三章 宏观部分:面向对象之类的层次结构与相互关系

第三章 宏观部分&#xff1a;面向对象之类的层次结构与相互关系关系has_a关系use_a关系&#xff08;友元关系&#xff09;is_a关系&#xff08;继承关系&#xff09;单继承多继承菱形继承多态&#xff08;polymorphic&#xff09;虚函数多态底层机制&#xff1a;虚函数、虚函数…

spring导入第三方资源

一、第三方资源配置管理 说明&#xff1a;以管理DataSource连接池对象为例讲解第三方资源配置管理 1 管理DataSource连接池对象 问题导入 配置数据库连接参数时&#xff0c;注入驱动类名是用driverClassName还是driver&#xff1f; 1.1 管理Druid连接池【重点】 数据库准备…