ArrayDeque解析

1 public abstract boolean add(E paramE);
2 public abstract boolean offer(E paramE);  // 加入元素
3 public abstract E remove();
4 public abstract E poll(); // 获取元素

 1 private void allocateElements(int numElements) {
 2         int initialCapacity = MIN_INITIAL_CAPACITY;
 3         // 如果指定的数组长度大于最小的值，需要计算数组大小。
 4         // 算法利用或运算和右移运算，计算结果始终为2的n次方，比如numElements的值为4、5、6、7时，initialCapacity的结果为8；numElements的值为8、9、10、11、12、13、14、15时，initialCapacity的结果为16。
 5         // 设计数组的长度为2的n次方是为循环链表考虑的，后面会解释。
 6         if (numElements >= initialCapacity) {
 7             initialCapacity = numElements;
 8             initialCapacity |= (initialCapacity >>>  1);
 9             initialCapacity |= (initialCapacity >>>  2);
10             initialCapacity |= (initialCapacity >>>  4);
11             initialCapacity |= (initialCapacity >>>  8);
12             initialCapacity |= (initialCapacity >>> 16);
13             initialCapacity++;
14             // 如果值太大溢出（即值小于0），需要缩小2倍
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     }

 1 private void doubleCapacity() {
 2         // assert head == tail;
 3         int p = head;
 4         int n = elements.length;
 5          // 头指针右边的长度
 6         int r = n - p;
 7         // 扩大2倍
 8         int newCapacity = n << 1;
 9         // 检测新的数组长度是否太大
10         if (newCapacity < 0)
11             throw new IllegalStateException("Sorry, deque too big");
12         Object[] a = new Object[newCapacity];
13         // 复制头指针右边的数据
14         System.arraycopy(elements, p, a, 0, r);
15         // 复制头指针左边的数据
16         System.arraycopy(elements, 0, a, r, p);
17         elements = a;
18         // 初始化头指针为0
19         head = 0;
20         // 初始化尾指针为n
21         tail = n;
22     }

 1 public void addFirst(E e) {
 2         if (e == null)
 3             throw new NullPointerException("e == null");
 4         // 在头部插入数据，头指针向左移动1，即减一，elements.length为2的n次方，所以elements.lenght-1的二进制表示为1111....1111。
 5         // 特殊情况：假设数组的长度为16，初始化时head为0，那么(head - 1) & (elements.length - 1)就是-1 & 15的值，负数的二进制为对应正数的二进制的补码，-1即为11111....1111,那么-1 & 15 = 15，如上图，当首次向队列头部插入数据时，head在数组的末尾。
 6         elements[head = (head - 1) & (elements.length - 1)] = e;
 7         // 头指针和尾指针相等时(即相遇)，表示当前的数组长度不够，需要扩大数组长度
 8         if (head == tail)
 9             doubleCapacity();
10     }

1 public void addLast(E e) {
2         if (e == null)
3             throw new NullPointerException("e == null");
4         elements[tail] = e;
5         // tail向右移动，如果头指针和尾指针相等时(即相遇)，表示当前的数组长度不够，需要扩大数组长度
6         if ( (tail = (tail + 1) & (elements.length - 1)) == head)
7             doubleCapacity();
8     }

 1 private class DeqIterator implements Iterator<E> {
 2         // 从头指针位置开始遍历
 3         private int cursor = head;
 4         private int fence = tail;
 5         private int lastRet = -1;
 6 
 7         public boolean hasNext() {
 8             return cursor != fence;
 9         }
10 
11         public E next() {
12             if (cursor == fence)
13                 throw new NoSuchElementException();
14             @SuppressWarnings("unchecked") E result = (E) elements[cursor];
15 
16             if (tail != fence || result == null)
17                 throw new ConcurrentModificationException();
18             lastRet = cursor;
19             // 每次加一，利用与运算，形成循环。比如，数组的长度为16，当cursor递增到15时，下面的计算应为16 & 15 = 0，cursor的值变为了0.
20             cursor = (cursor + 1) & (elements.length - 1);
21             return result;
22         }
23 
24         public void remove() {
25             if (lastRet < 0)
26                 throw new IllegalStateException();
27             if (delete(lastRet)) { // if left-shifted, undo increment in next()
28                 cursor = (cursor - 1) & (elements.length - 1);
29                 fence = tail;
30             }
31             lastRet = -1;
32         }
33     }