数组

Java 数组是固定长度的相同类型的元素的列表,数组下标从 0 开始,通过下标随机访问数组元素。数组初始化后不能改变大小,初始化数组(分配内存空间,初始化默认值)的方式如下:

  1. // 静态初始化
  2. int[] array0 = {1, 2, 3};
  3. int[] array1 = new int[]{1, 2, 3, 4, 5};
  4. // 动态初始化
  5. int[] array2 = new int[10];
  6. array2[0] = 1;
  7. array2[1] = 2;
  8. array2[2] = 3;
  9. // 数组遍历
  10. for (int i = 0; i < array2.length; ++i) {
  11. System.out.print(array2[i]);
  12. }
  13. // 增强 for- each 循环
  14. for (int i : array2) {
  15. System.out.print(i);
  16. }

java.util.Arrays 类提供了数组排序、查找、拷贝等方法,还提供了数组转为集合的方法。数组五种拷贝方式:

  1. int[] x = {1, 2, 3, 4, 5};
  2. int[] y = new int[5];
  3. // for 循环
  4. // y = x.clone();
  5. // System.arraycopy(x, 0, y, 0, 5);
  6. // y = Arrays.copyOf(x, 5);
  7. // y = Arrays.copyOfRange(x, 0, 5);
  8. // 以上方法一维数组对基本类型是深拷贝,对引用类型是浅拷贝

数组拷贝最快的方式应该就是 System.arraycopy() 方法了,它由 JVM 专门实现基于内存的拷贝:

  1. @HotSpotIntrinsicCandidate
  2. public static native void arraycopy(Object src, int srcPos, Object dest, int destPos, int length);

Collection

jdk-collections-collection.png
Collection 接口提供的方法如下:

  • 获取元素个数 size()、转为数组 toArray(T[] a)
  • 末尾添加 add(E e) 、删除第一个匹配元素 remove(Object o)、清空 clear()
  • 是否没有元素 isEmpty()、是否包含 contains(Object o)、是否包含全部 containsAll(Collection<?> c)
  • 并集 addAll(Collection<? extends E> c)、交集 retainAll(Collection<?> c)、差集 removeAll(Collection<?> c)

    List JDK1.2

    List 是有序、可重复元素(通常可以为 null)的列表。List 提供了以下基本方法:

  • 获取 get(int index)、修改 set(int index, E element)

  • 查找第一个匹配的下标 indexOf(Object o)、查找最后一个匹配的下标 lastIndexOf(Object o)
  • 截取 subList(int fromIndex, int toIndex)
  • 排序 sort(Comparator<? super E> c、迭代器遍历 listIterator(int index)
  • 创建不可变列表 of(E e1)JDK 9、复制不能为 null 的元素的不可变列表 copyOf(Collection<? extends E> coll)JDK 10

    ArrayList

    基于数组的可动态扩容的列表,可以通过索引随机访问元素。
    ArrayList 的 size()isEmpty()get(int index)set(int index, E element)iterator() 方法以固定时间运行;通过 add 方法插入 n 个元素以 O(n) 固定时间运行;其它大部分操作以线性时间运行。 details ArrayList 源码浅析(JDK 15)ArrayList 底层结构 ```java // ArrayList 基于数组 elementData 实现,通过 size 来记录元素个数 transient Object[] elementData; private int size;

// 还可以看到存储的对象都是 Object 类型,它使用的是泛型约束

  1. **数组初始化方法源码如下:**
  2. ```java
  3. // 构造器
  4. public ArrayList() {
  5. this.elementData = DEFAULTCAPACITY_EMPTY_ELEMENTDATA;
  6. }
  7. public ArrayList(int initialCapacity) {
  8. if (initialCapacity > 0) {
  9. this.elementData = new Object[initialCapacity];
  10. } else if (initialCapacity == 0) {
  11. this.elementData = EMPTY_ELEMENTDATA;
  12. } else {
  13. throw new IllegalArgumentException("Illegal Capacity: " + initialCapacity);
  14. }
  15. }
  16. public ArrayList(Collection<? extends E> c) {
  17. Object[] a = c.toArray();
  18. if ((size = a.length) != 0) {
  19. if (c.getClass() == ArrayList.class) {
  20. elementData = a;
  21. } else {
  22. elementData = Arrays.copyOf(a, size, Object[].class);
  23. }
  24. } else {
  25. elementData = EMPTY_ELEMENTDATA;
  26. }
  27. }

以上方法中可看到,初始化数组时,如果给定的容量不为 0,则直接分配指定大小的容量创建数组 elementData;如果为 0,则初始化为默认的空数组。
数组新增元素源码如下:

  1. // 添加元素
  2. public boolean add(E e) {
  3. modCount++;
  4. add(e, elementData, size);
  5. return true;
  6. }
  7. private void add(E e, Object[] elementData, int s) {
  8. if (s == elementData.length)
  9. elementData = grow();
  10. elementData[s] = e;
  11. size = s + 1;
  12. }
  13. public void add(int index, E element) {
  14. rangeCheckForAdd(index);
  15. modCount++;
  16. final int s;
  17. Object[] elementData;
  18. if ((s = size) == (elementData = this.elementData).length)
  19. elementData = grow();
  20. System.arraycopy(elementData, index,
  21. elementData, index + 1,
  22. s - index);
  23. elementData[index] = element;
  24. size = s + 1;
  25. }
  26. public boolean addAll(Collection<? extends E> c) {
  27. Object[] a = c.toArray();
  28. modCount++;
  29. int numNew = a.length;
  30. if (numNew == 0)
  31. return false;
  32. Object[] elementData;
  33. final int s;
  34. if (numNew > (elementData = this.elementData).length - (s = size))
  35. elementData = grow(s + numNew);
  36. System.arraycopy(a, 0, elementData, s, numNew);
  37. size = s + numNew;
  38. return true;
  39. }
  40. public boolean addAll(int index, Collection<? extends E> c) {
  41. rangeCheckForAdd(index);
  42. Object[] a = c.toArray();
  43. modCount++;
  44. int numNew = a.length;
  45. if (numNew == 0)
  46. return false;
  47. Object[] elementData;
  48. final int s;
  49. if (numNew > (elementData = this.elementData).length - (s = size))
  50. elementData = grow(s + numNew);
  51. int numMoved = s - index;
  52. if (numMoved > 0)
  53. System.arraycopy(elementData, index,
  54. elementData, index + numNew,
  55. numMoved);
  56. System.arraycopy(a, 0, elementData, index, numNew);
  57. size = s + numNew;
  58. return true;
  59. }

新增元素时,如果新增的元素个数超过当前剩余容量,则调用 grow() 或者 grow(int) 方法先扩容;然后通过 System.arraycopy() 方法插入元素。我们看下 grow 方法的逻辑:
grow 自动扩容源码如下:

  1. // 两个空数组,用于标识第一次应该分配多大容量
  2. private static final Object[] EMPTY_ELEMENTDATA = {}; // 初始化列表时给定的容量为 0
  3. private static final Object[] DEFAULTCAPACITY_EMPTY_ELEMENTDATA = {}; // 初始化列表时没有指定容量
  4. private static final int DEFAULT_CAPACITY = 10; // 默认扩充容量
  5. // 具体扩容方法
  6. private Object[] grow() {
  7. return grow(size + 1);
  8. }
  9. // 参数为数组目标大小
  10. private Object[] grow(int minCapacity) {
  11. int oldCapacity = elementData.length;
  12. // 如果是一个指定为 0 容量的初始化列表或者列表中已有元素,则调用 ArraysSupport.newLength 方法扩充容量,然后底层调用 System.arraycopy() 方法复制已有的元素
  13. if (oldCapacity > 0 || elementData != DEFAULTCAPACITY_EMPTY_ELEMENTDATA) {
  14. int newCapacity = ArraysSupport.newLength(oldCapacity,
  15. minCapacity - oldCapacity, /* minimum growth */
  16. oldCapacity >> 1 /* preferred growth */);
  17. return elementData = Arrays.copyOf(elementData, newCapacity);
  18. } else {
  19. // 如果是一个没有指定容量的初始化列表,则直接分配一个 Math.max(DEFAULT_CAPACITY, minCapacity) 大小的数组返回
  20. return elementData = new Object[Math.max(DEFAULT_CAPACITY, minCapacity)];
  21. }
  22. }

手动扩容源码如下:

  1. // 手动扩容方法
  2. public void ensureCapacity(int minCapacity) {
  3. // 可以看到调用此方法符合条件才会扩容,需要满足要增加的容量要超过当前数组的大小并且不能超过 Integer.MAX_VALUE - 8,并且不能是无参构造刚初始化好的列表
  4. if (minCapacity > elementData.length
  5. && !(elementData == DEFAULTCAPACITY_EMPTY_ELEMENTDATA
  6. && minCapacity <= DEFAULT_CAPACITY)) {
  7. modCount++;
  8. grow(minCapacity);
  9. }
  10. }
  11. // 调整容量到元素个数,减少空间使用
  12. public void trimToSize() {
  13. modCount++;
  14. if (size < elementData.length) {
  15. elementData = (size == 0)
  16. ? EMPTY_ELEMENTDATA
  17. : Arrays.copyOf(elementData, size);
  18. }
  19. }

ArraysSupport.newLength 具体扩容大小源码

  1. // 扩容参数为:当前数组大小、需要大小、当前的一半(右移一位相当于整除)
  2. public static int newLength(int oldLength, int minGrowth, int prefGrowth) {
  3. // assert oldLength >= 0
  4. // assert minGrowth > 0
  5. int newLength = Math.max(minGrowth, prefGrowth) + oldLength;
  6. if (newLength - MAX_ARRAY_LENGTH <= 0) {
  7. return newLength;
  8. }
  9. return hugeLength(oldLength, minGrowth);
  10. }
  11. private static int hugeLength(int oldLength, int minGrowth) {
  12. int minLength = oldLength + minGrowth;
  13. if (minLength < 0) { // overflow
  14. throw new OutOfMemoryError("Required array length too large");
  15. }
  16. if (minLength <= MAX_ARRAY_LENGTH) {
  17. return MAX_ARRAY_LENGTH;
  18. }
  19. return Integer.MAX_VALUE;
  20. }

通过 grow 方法可以知道了,如果是一个没有指定容量的初始化列表,根据新元素个数和 10 的最大值返回一个新的数组;
如果是一个指定为 0 容量的初始化列表或者列表中已有元素,则进行扩充,如果新增的元素个数超过了当前数组大小的一半,则尝试直接扩充为目标大小;否则尝试扩充为当前数组大小的 1.5 倍。如果超出 Integer.MAX_VALUE - 8,则再次尝试分配,如果新增元素的个数在内存范围内,小于 Integer.MAX_VALUE - 8 则直接扩充为 Integer.MAX_VALUE - 8,否则扩充为 Integer.MAX_VALUEInteger.MAX_VALUE - 8 是因为有些虚拟机要在数组中保留标题字。
总结:

  • 初始化时直接根据元素个数大小分配数组
  • 新增元素,不够用时才扩容,扩容根据初始化方式有所不同:
    • 如果是没初始化容量的空列表,扩充为 10 ,目标大小超过 10 则扩充为目标大小
    • 否则扩充为当前数组大小的 1.5 倍,目标大小超过 1.5 倍则扩充为目标大小

      Vector

      和 ArrayList 几乎一样,只不过 Vector 是同步的,保证线程安全。

      Stack

      继承自 Vector,提供先进先出(FIFO)的简单的栈。官方推荐使用含有更完整的堆栈操作的 Deque 的实现类。

      LinkedList

      基于双向链表实现的列表。它只保存了第一个和最后一个 Node 节点,根据索引访问其它元素都需要遍历。
      LinkedList 实现了 List 和 Deque 接口,所以它是有序的,但是支持双向访问,可以作为队列、栈、双向队列使用。 details LinkedList 源码浅析(JDK 15)底层数据结构 ```java transient int size = 0; // 元素个数 transient Node first; // 头节点 transient Node last; // 尾节点

// Node 节点是个内部类,有两个指针指向上一个和下一个 Node private static class Node { E item; Node next; Node prev;

  1. Node(Node<E> prev, E element, Node<E> next) {
  2. this.item = element;
  3. this.next = next;
  4. this.prev = prev;
  5. }

}

  1. 所有的操作最终都是基于 Node 的增删操作,如下:
  2. ```java
  3. // 在头部添加节点
  4. private void linkFirst(E e) {
  5. final Node<E> f = first;
  6. final Node<E> newNode = new Node<>(null, e, f);
  7. first = newNode;
  8. if (f == null)
  9. last = newNode;
  10. else
  11. f.prev = newNode;
  12. size++;
  13. modCount++;
  14. }
  15. // 在尾部添加节点
  16. void linkLast(E e) {
  17. final Node<E> l = last;
  18. final Node<E> newNode = new Node<>(l, e, null);
  19. last = newNode;
  20. if (l == null)
  21. first = newNode;
  22. else
  23. l.next = newNode;
  24. size++;
  25. modCount++;
  26. }
  27. // 在中间插入节点
  28. void linkBefore(E e, Node<E> succ) {
  29. // assert succ != null;
  30. final Node<E> pred = succ.prev;
  31. final Node<E> newNode = new Node<>(pred, e, succ);
  32. succ.prev = newNode;
  33. if (pred == null)
  34. first = newNode;
  35. else
  36. pred.next = newNode;
  37. size++;
  38. modCount++;
  39. }
  40. // 删除第一个节点
  41. private E unlinkFirst(Node<E> f) {
  42. // assert f == first && f != null;
  43. final E element = f.item;
  44. final Node<E> next = f.next;
  45. f.item = null;
  46. f.next = null; // help GC
  47. first = next;
  48. if (next == null)
  49. last = null;
  50. else
  51. next.prev = null;
  52. size--;
  53. modCount++;
  54. return element;
  55. }
  56. // 删除最后一个节点
  57. private E unlinkLast(Node<E> l) {
  58. // assert l == last && l != null;
  59. final E element = l.item;
  60. final Node<E> prev = l.prev;
  61. l.item = null;
  62. l.prev = null; // help GC
  63. last = prev;
  64. if (prev == null)
  65. first = null;
  66. else
  67. prev.next = null;
  68. size--;
  69. modCount++;
  70. return element;
  71. }
  72. // 删除中间节点
  73. E unlink(Node<E> x) {
  74. // assert x != null;
  75. final E element = x.item;
  76. final Node<E> next = x.next;
  77. final Node<E> prev = x.prev;
  78. if (prev == null) {
  79. first = next;
  80. } else {
  81. prev.next = next;
  82. x.prev = null;
  83. }
  84. if (next == null) {
  85. last = prev;
  86. } else {
  87. next.prev = prev;
  88. x.next = null;
  89. }
  90. x.item = null;
  91. size--;
  92. modCount++;
  93. return element;
  94. }

查找节点源码如下:

  1. Node<E> node(int index) {
  2. // assert isElementIndex(index);
  3. // 如果下标小于一半,则从头部开始查找,否则从尾部开始查找
  4. if (index < (size >> 1)) {
  5. Node<E> x = first;
  6. for (int i = 0; i < index; i++)
  7. x = x.next;
  8. return x;
  9. } else {
  10. Node<E> x = last;
  11. for (int i = size - 1; i > index; i--)
  12. x = x.prev;
  13. return x;
  14. }
  15. }

Set JDK1.2

Set 是包含不可重复元素(通常可以为 null)的集合。Set 提供了以下基本方法:

  • 创建不可变集合 of(E e1)JDK 9、复制不能为 null 的元素的不可变集合 copyOf(Collection<? extends E> coll)JDK 10

    HashSet

    内部使用 HashMap 实现的集合。
    它为基本操作 add、remove、contains 和 size 提供了恒定的时间性能,但是对该集合迭代使用的时间和内部元素个数及 HashMap 桶的个数之和有关。 details HashSet 源码浅析(JDK 15)底层数据结构
    1. private transient HashMap<E,Object> map;
    2. private static final Object PRESENT = new Object();
    构造器 ```java // HashMap 实例默认初始容量为 16,加载因子为 0.75

public HashSet() { map = new HashMap<>(); }

// 以指定集合创建时,HashMap 保证初始容量可以容纳指定集合中的元素 public HashSet(Collection<? extends E> c) { map = new HashMap<>(Math.max((int) (c.size()/.75f) + 1, 16)); addAll(c); } public HashSet(int initialCapacity, float loadFactor) { map = new HashMap<>(initialCapacity, loadFactor); } public HashSet(int initialCapacity) { map = new HashMap<>(initialCapacity); }

// LinkedHashSet 使用 HashSet(int initialCapacity, float loadFactor, boolean dummy) { map = new LinkedHashMap<>(initialCapacity, loadFactor); }

  1. <a name="jVtn9"></a>
  2. ### LinkedHashSet
  3. 内部使用 LinkedHashMap 实现的有序集合。<br />此类的迭代时间不受容量影响;由于添加同样的元素不会改变它原有的顺序,常用于通过构造器 `LinkedHashSet(Collection<? extends E> c)` 将含重复元素的集合去重并保持原来的顺序,相比 TreeSet 更轻量。
  4. <a name="g1uK7"></a>
  5. ### TreeSet
  6. 基于 TreeMap 的有序集合。保证 log(n) 的时间复杂度。
  7. <a name="ijWpv"></a>
  8. ### EnumSetJDK 5
  9. JDK 5 新增的专门用于枚举类型的枚举集合。可以通过集合操作处理枚举值。它提供的方法如下:
  10. - 返回该枚举类所有枚举值的集合 `allOf(Class<E> elementType)`
  11. - 返回该枚举类的空集合 `noneOf(Class<E> elementType)`
  12. - 返回该枚举类部分枚举值的集合 `EnumSet<E> copyOf(EnumSet<E> s)`、`copyOf(Collection<E> c)`、`EnumSet<E> of(E e)`、`range(E from, E to)`
  13. - 补集 `complementOf(EnumSet<E> s)`
  14. 它内部使用位向量实现,非常紧凑和高效,具有极好的时空性能,几乎所有操作都在固定时间内运行。
  15. ---
  16. <a name="u3mAa"></a>
  17. ## QueueJDK 5
  18. JDK 5 新增的 Queue 是基于优先级堆实现的无限优先级队列,该队列中的元素会根据优先级进行排序。队列中通常不能存储 null 值(LinkedList 除外),队列的每种操作都有两种形式:
  19. - 一种是操作失败会抛出异常
  20. - `add(E e)`
  21. - `remove()`
  22. - `element()`
  23. - 一种是操作失败会返回特殊值 null 或者 false
  24. - `offer(E e)`
  25. - `poll()`
  26. - `peek()`
  27. <a name="RGTgi"></a>
  28. ### PriorityQueue
  29. PriorityQueue 是基于二进制堆实现的优先级队列,可通过构造器传入元素优先级比较器 Comparator,不指定则默认元素的自然比较排序,即元素需要实现 Comparable,是可比较的。
  30. details PriorityQueue 源码浅析(JDK 15)**底层数据结构**
  31. ```java
  32. // 表示基于平衡二叉树的最小堆的优先级队列,queue[n] 的两个孩子是 queue[2 * n + 1] 和 queue[2 *(n + 1)]
  33. transient Object[] queue;
  34. int size;
  35. // 通过比较器实现对于堆中的每个节点小于等于它的孩子节点,比较器为 null 则使用元素的自然排序
  36. @SuppressWarnings("serial") // Conditionally serializable
  37. private final Comparator<? super E> comparator;
  38. transient int modCount;

堆数组的扩容源码如下:

  1. private void grow(int minCapacity) {
  2. int oldCapacity = queue.length;
  3. // Double size if small; else grow by 50%
  4. // 如果当前大小小于 64 则每次增加 2,否则增加一半
  5. int newCapacity = ArraysSupport.newLength(oldCapacity,
  6. minCapacity - oldCapacity, /* minimum growth */
  7. oldCapacity < 64 ? oldCapacity + 2 : oldCapacity >> 1
  8. /* preferred growth */);
  9. queue = Arrays.copyOf(queue, newCapacity);
  10. }

对于堆调整的源码如下:

  1. // 由于Floyd (1964) 产生的 O(size) 算法,在整个树中建立堆不变式:
  2. private void heapify() {
  3. final Object[] es = queue;
  4. int n = size, i = (n >>> 1) - 1;
  5. final Comparator<? super E> cmp;
  6. if ((cmp = comparator) == null)
  7. for (; i >= 0; i--)
  8. siftDownComparable(i, (E) es[i], es, n);
  9. else
  10. for (; i >= 0; i--)
  11. siftDownUsingComparator(i, (E) es[i], es, n, cmp);
  12. }
  13. private static <T> void siftUpComparable(int k, T x, Object[] es) {
  14. Comparable<? super T> key = (Comparable<? super T>) x;
  15. while (k > 0) {
  16. int parent = (k - 1) >>> 1;
  17. Object e = es[parent];
  18. if (key.compareTo((T) e) >= 0)
  19. break;
  20. es[k] = e;
  21. k = parent;
  22. }
  23. es[k] = key;
  24. }
  25. private static <T> void siftUpUsingComparator(
  26. int k, T x, Object[] es, Comparator<? super T> cmp) {
  27. while (k > 0) {
  28. int parent = (k - 1) >>> 1;
  29. Object e = es[parent];
  30. if (cmp.compare(x, (T) e) >= 0)
  31. break;
  32. es[k] = e;
  33. k = parent;
  34. }
  35. es[k] = x;
  36. }
  37. private static <T> void siftDownComparable(int k, T x, Object[] es, int n) {
  38. // assert n > 0;
  39. Comparable<? super T> key = (Comparable<? super T>)x;
  40. int half = n >>> 1; // loop while a non-leaf
  41. while (k < half) {
  42. int child = (k << 1) + 1; // assume left child is least
  43. Object c = es[child];
  44. int right = child + 1;
  45. if (right < n &&
  46. ((Comparable<? super T>) c).compareTo((T) es[right]) > 0)
  47. c = es[child = right];
  48. if (key.compareTo((T) c) <= 0)
  49. break;
  50. es[k] = c;
  51. k = child;
  52. }
  53. es[k] = key;
  54. }
  55. private static <T> void siftDownUsingComparator(
  56. int k, T x, Object[] es, int n, Comparator<? super T> cmp) {
  57. // assert n > 0;
  58. int half = n >>> 1;
  59. while (k < half) {
  60. int child = (k << 1) + 1;
  61. Object c = es[child];
  62. int right = child + 1;
  63. if (right < n && cmp.compare((T) c, (T) es[right]) > 0)
  64. c = es[child = right];
  65. if (cmp.compare(x, (T) c) <= 0)
  66. break;
  67. es[k] = c;
  68. k = child;
  69. }
  70. es[k] = x;
  71. }

DequeJDK 6

Deque 接口是继承了 Queue 接口的双端队列,支持从队列两端进行操作。

ArrayDeque

ArrayDeque 是基于可调整大小的圆形数组的无界双端队列。官方说,当用作堆栈时,此类比 Stack 类快;当用作队列时,此类比 LinkedList 类快。
ArrayDeque 大部分方法以固定时间执行,除了批量操作及 remove(Object)removeFirstOccurrence(Object o)removeLastOccurrence(Object o)contains(Object o)iterator.remove() 以线性时间运行。 ArrayDeque 源码浅析(JDK 15)底层数据结构

  1. // 虚拟机擅长优化简单的数组循环,其中索引在有效切片上递增或递减。
  2. // 因为在圆形数组中,元素通常存储在两个不相交的切片中,所以我们通过为元素上的所有遍历编写不寻常的嵌套循环来帮助虚拟机.
  3. // 仅具有一个热的内部循环主体而不是两个或三个,可以简化人工维护,并鼓励VM循环内联到调用者中。
  4. // 存储双端队列元素的数组,其中每个不含元素的位置都为 null,数组至少有一个 null(在尾部)
  5. transient Object[] elements;
  6. // 头部索引,0 <= head < elements.length,双端队列为空时 head = tail
  7. transient int head;
  8. // 尾部索引,作为下一个元素插入到尾部的索引,elements[tail] 始终为 null
  9. transient int tail;
  10. private static final int MAX_ARRAY_SIZE = Integer.MAX_VALUE - 8;

容量扩充源码如下:

  1. private void grow(int needed) {
  2. // overflow-conscious code
  3. final int oldCapacity = elements.length;
  4. int newCapacity;
  5. // Double capacity if small; else grow by 50%
  6. int jump = (oldCapacity < 64) ? (oldCapacity + 2) : (oldCapacity >> 1);
  7. if (jump < needed
  8. || (newCapacity = (oldCapacity + jump)) - MAX_ARRAY_SIZE > 0)
  9. newCapacity = newCapacity(needed, jump);
  10. final Object[] es = elements = Arrays.copyOf(elements, newCapacity);
  11. // Exceptionally, here tail == head needs to be disambiguated
  12. if (tail < head || (tail == head && es[head] != null)) {
  13. // wrap around; slide first leg forward to end of array
  14. int newSpace = newCapacity - oldCapacity;
  15. System.arraycopy(es, head,
  16. es, head + newSpace,
  17. oldCapacity - head);
  18. for (int i = head, to = (head += newSpace); i < to; i++)
  19. es[i] = null;
  20. }
  21. }
  22. /** Capacity calculation for edge conditions, especially overflow. */
  23. private int newCapacity(int needed, int jump) {
  24. final int oldCapacity = elements.length, minCapacity;
  25. if ((minCapacity = oldCapacity + needed) - MAX_ARRAY_SIZE > 0) {
  26. if (minCapacity < 0)
  27. throw new IllegalStateException("Sorry, deque too big");
  28. return Integer.MAX_VALUE;
  29. }
  30. if (needed > jump)
  31. return minCapacity;
  32. return (oldCapacity + jump - MAX_ARRAY_SIZE < 0)
  33. ? oldCapacity + jump
  34. : MAX_ARRAY_SIZE;
  35. }

双端队列操作源码如下:

  1. /**
  2. * Circularly increments i, mod modulus.
  3. * Precondition and postcondition: 0 <= i < modulus.
  4. */
  5. static final int inc(int i, int modulus) {
  6. if (++i >= modulus) i = 0;
  7. return i;
  8. }
  9. /**
  10. * Circularly decrements i, mod modulus.
  11. * Precondition and postcondition: 0 <= i < modulus.
  12. */
  13. static final int dec(int i, int modulus) {
  14. if (--i < 0) i = modulus - 1;
  15. return i;
  16. }
  17. /**
  18. * Circularly adds the given distance to index i, mod modulus.
  19. * Precondition: 0 <= i < modulus, 0 <= distance <= modulus.
  20. * @return index 0 <= i < modulus
  21. */
  22. static final int inc(int i, int distance, int modulus) {
  23. if ((i += distance) - modulus >= 0) i -= modulus;
  24. return i;
  25. }
  26. /**
  27. * Subtracts j from i, mod modulus.
  28. * Index i must be logically ahead of index j.
  29. * Precondition: 0 <= i < modulus, 0 <= j < modulus.
  30. * @return the "circular distance" from j to i; corner case i == j
  31. * is disambiguated to "empty", returning 0.
  32. */
  33. static final int sub(int i, int j, int modulus) {
  34. if ((i -= j) < 0) i += modulus;
  35. return i;
  36. }

Map

jdk-collections-map.png
Map 是存储键值对的对象,键不能为 null,每个键最多映射一个值。Map 接口提供的方法如下:

  • 获取键值对个数 size()、清空键值对 clear()
  • 判断是否没有键值对 isEmpty()、是否包含键 containsKey(Object o)、是否包含值 containsValue(Object o)
  • 获取键对应的值 get(Object o)、获取键对应的值,没有返回提供的默认值 getOrDefault(Object key, V defaultValue) JDK 8
  • 添加键值对 put(K k, V v)、批量添加 putAll(Map<? extends K, ? extends V> m)、键有值返回,没有添加 putIfAbsent(K key, V value) JDK 8
  • 删除键值对 remove(Object o)、删除对应的键值对 remove(Object key, Object value) JDK 8
  • 替换键的值 replace(K key, V value)replace(K key, V oldValue, V newValue)replaceAll(BiFunction<? super K, ? super V, ? extends V> function) JDK 8
  • 遍历 forEach(BiConsumer<? super K, ? super V> action) JDK 8
  • 指定键值关系 compute()mergeJDK 8
  • 构造不可变哈希表 of(K k1, V v1) JDK 9、ofEntries(Entry<? extends K, ? extends V>... entries) JDK 9、entry(K k, V v) JDK 9、copyOf(Map<? extends K, ? extends V> map) JDK 10

Map 提供了三种视图:

  • 键的集合 keySet()
  • 值的集合 values()
  • 键值对的集合 entrySet()

    HashMap

    基于哈希表实现。
    它为基本的 get、put 操作提供恒定时间的性能,但是迭代性能和桶的数量及键值对的数量成比例,如果需要迭代,初始容量不要太高,负载因子不要太低。
    HashMap 的实例有两个影响性能的参数:初始容量和负载因子。如果哈希表中的条目数量超过负载因子和当前容量的乘积,哈希表会重建。如果要存储很对键值对,指定初始容量将提高存储效率,而不是自动扩容。如果键的 hashcode() 相同肯定会降低性能,所以尽量提高键的可比性(Comparable)。 HashMap 源码浅析(JDK 15)底层数据结构 ```java // 键值对节点 static class Node implements Map.Entry { final int hash; final K key; V value; Node next;

    Node(int hash, K key, V value, Node next) {

    1. this.hash = hash;
    2. this.key = key;
    3. this.value = value;
    4. this.next = next;

    }

    public final K getKey() { return key; } public final V getValue() { return value; } public final String toString() { return key + “=” + value; }

    public final int hashCode() {

    1. return Objects.hashCode(key) ^ Objects.hashCode(value);

    }

    public final V setValue(V newValue) {

    1. V oldValue = value;
    2. value = newValue;
    3. return oldValue;

    }

    public final boolean equals(Object o) {

    1. if (o == this)
    2. return true;
    3. if (o instanceof Map.Entry) {
    4. Map.Entry<?,?> e = (Map.Entry<?,?>)o;
    5. if (Objects.equals(key, e.getKey()) &&
    6. Objects.equals(value, e.getValue()))
    7. return true;
    8. }
    9. return false;

    } }

transient Node[] table; // 哈希表,首次使用时初始化,扩容时分配长度始终是 2 的幂 transient int size; // 键值对个数 int threshold; // capacity * load factor,下一次分配的大小 final float loadFactor; // 负载因子

transient Set> entrySet; transient int modCount;

static final int DEFAULT_INITIAL_CAPACITY = 1 << 4; // aka 16 初始容量,必须为 2 的幂 static final int MAXIMUM_CAPACITY = 1 << 30; // 最大容量 static final float DEFAULT_LOAD_FACTOR = 0.75f; static final int TREEIFY_THRESHOLD = 8; // 桶的个数,桶会转为树,该值必须大于 2,并且至少应为 8 才能从树再变回桶 static final int UNTREEIFY_THRESHOLD = 6; // 取消树化的仓位阈值,小于 TREEIFY_THRESHOLD,最大为 6 static final int MIN_TREEIFY_CAPACITY = 64; // 可以树化的最小容量,应该至少为 4 * TREEIFY_THRESHOLD

  1. <a name="F7C0K"></a>
  2. ## LinkedHashMap
  3. 基于哈希表和双向链表实现的有序的键值对集合。<br />默认根据插入顺序排序,但是也提供了构造器 `LinkedHashMap(int initialCapacity, float loadFactor, boolean accessOrder)` 可以指定排序模式(true 根据访问顺序,false 根据插入顺序),根据访问顺序可以实现最近最少访问的哈希表,非常适合构建 LRU 缓存。
  4. ```java
  5. import java.util.LinkedHashMap;
  6. import java.util.Map;
  7. public class Main {
  8. /**
  9. * 使用 LinkedHashMap实现 LRU 缓存算法,LRU 缓存算法即删除最近最久未使用的数据
  10. * <p>
  11. * 实现思路为:
  12. * 1.每次访问一个数据则把这个数据移到队列尾部
  13. * 2.缓存满了则删除队列首部的数据,即删除最久未使用的,
  14. * 3.删除后,后面的数据需要向前补位
  15. * <p>
  16. * 综合考虑使用 LinkedHashMap 来实现,原因为:
  17. * 1.使用链表结构,移动数据比较快需要 O(1) 时间;使用数组需要 O(n) 时间
  18. * 2.其提供带参数的构造函数,设置使用访问顺序遍历
  19. * 3.在访问顺序下,其 get 方法除了返回数据还会将访问的数据放到链表尾部,每次只需 remove 首部的数据
  20. */
  21. public static class LRUCache<K, V> extends LinkedHashMap<K, V> {
  22. private static final long serialVersionUID = 1L;
  23. // 缓存最大容量
  24. private final int maxCapacity;
  25. public LRUCache(int maxCapacity) {
  26. super(maxCapacity, 0.75f, true);
  27. this.maxCapacity = maxCapacity;
  28. }
  29. @Override
  30. public boolean removeEldestEntry(Map.Entry<K, V> eldest) {
  31. return size() > maxCapacity;
  32. }
  33. }
  34. public static void main(String[] args) {
  35. // 测试一下,设置缓存最大容量为4
  36. Map<Integer, String> map = new LRUCache<>(4);
  37. map.put(1, "h");
  38. map.put(2, "he");
  39. map.put(3, "hel");
  40. map.put(4, "hell");
  41. map.put(5, "hello");
  42. map.get(3);
  43. // 将依次输出2、4、5、3,因存储5个数据超出缓存最大容量,自动删除首部数据1;之后访问3,将3移到尾部
  44. for (Object key : map.keySet()) {
  45. System.out.println(key);
  46. }
  47. }
  48. }

TreeMap

基于红黑树实现的有序的键值对集合。

EnumMap

WeakHashMap

基于哈希表实现的带有弱键的集合,当键被回收,则键值对会自动删除。

IdentityHashMap

基于哈希表实现的集合,比较键和值时使用 == 而不是 equals(),用于序列化和深拷贝。

Hashtable

与 HashMap 类似,但 Hashtable 不允许空值,并且是同步的,保证线程安全。

Properties

线程安全的属性表,每个键值对都是一个字符串。可以持久化。


fail - fast 机制

当创建迭代器之后,如果集合的结构改变(除了通过迭代器的 remove()add() 方法之外),就会尽最大努力抛出 ConcurrentModificationException 异常。该机制仅用于检测错误,不能用于异常处理。

Collections 类

Collections 类提供了静态方法对集合进行操作,或者通过包装返回新集合。
以上集合除了 Vector、Hashtable、Properties 都是非线程安全的,如果需要并发处理,则需要 Collecitons 类提供的同步包装方法,使用如下包装方法返回的集合进行迭代器或 Stream 遍历时需要手动使用 synchronized 同步块包裹:

  • synchronizedList(List<T> list)
  • synchronizedSet(Set<T> s)synchronizedSortedSet(SortedSet<T> s)synchronizedNavigableSet(NavigableSet<T> s)
  • synchronizedMap(Map<K,V> m)synchronizedSortedMap(SortedMap<K,V> m)synchronizedNavigableMap(NavigableMap<K,V> m)

如果需要让集合只读,可以使用只读包装方法:

  • unmodifiableList(List<? extends T> list) 等(同上 unmodifiable 开头)

还可以返回只读的空集合或者单例集合:

  • emptyList() EMPTY_LIST 等(同上 empty 开头)
  • singletonList(T o) 只能含有一个元素的不可变列表
  • singleton(T o) 只能含有一个元素的不可变集合
  • singletonMap(K key, V value),只能含有一个键值对的不可变集合

Collections 类还提供了很多实用方法:

  • 集合反转 reverse(List<?> list)
  • 随机打乱集合元素 shuffle(List<?> list)
  • 集合元素换位 swap(List<?> list, int i, int j)
  • 替换全部元素 fill(List<? super T> list, T obj)
  • 集合复制 copy(List<? super T> dest, List<? extends T> src)
  • 返回最值 min(Collection<? extends T> coll)max(Collection<? extends T> coll)

    并发安全

    使用 Collections 类提供的方法对不安全的集合进行包装需要手动进行同步,为了避免同步 JDK 5 增加了如下并发集合类:

    CopyOnWriteArrayList

    替代 ArrayList 的并发安全的列表。

    CopyOnWriteArraySet

    底层使用 CopyOnWriteArrayList 进行所有操作的并发安全的集合。

    ConcurrentHashMap

    和 Hashtable 类似的并发安全的哈希表。

    ConcurrentSkipListMapJDK 6

    基于 SkipLists 的变体实现的可按顺序排列的并发安全的哈希表。

注意:
SyncronizedMap 和 ConcurrentHashMap 等并发安全的集合,在进行查询并删除这种联合操作时也是线程不安全的,需要对整个集合使用 syncronized 块包裹。