| /* |
| * Copyright (C) 2008 The Guava Authors |
| * |
| * Licensed under the Apache License, Version 2.0 (the "License"); |
| * you may not use this file except in compliance with the License. |
| * You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| package com.google.common.collect; |
| |
| import static com.google.common.base.Preconditions.checkElementIndex; |
| import static com.google.common.base.Preconditions.checkPositionIndex; |
| import static com.google.common.collect.CollectPreconditions.checkEntryNotNull; |
| |
| import com.google.common.annotations.GwtCompatible; |
| import com.google.common.annotations.VisibleForTesting; |
| import java.util.AbstractMap; |
| import java.util.Arrays; |
| import java.util.Map.Entry; |
| import org.checkerframework.checker.nullness.compatqual.NullableDecl; |
| |
| /** |
| * A hash-based implementation of {@link ImmutableMap}. |
| * |
| * @author Louis Wasserman |
| */ |
| @GwtCompatible(serializable = true, emulated = true) |
| final class RegularImmutableMap<K, V> extends ImmutableMap<K, V> { |
| private static final byte ABSENT = -1; |
| |
| // Max size is halved due to indexing into double-sized alternatingKeysAndValues |
| private static final int BYTE_MAX_SIZE = 1 << (Byte.SIZE - 1); // 2^7 = 128 |
| private static final int SHORT_MAX_SIZE = 1 << (Short.SIZE - 1); // 2^15 = 32_768 |
| |
| private static final int BYTE_MASK = (1 << Byte.SIZE) - 1; // 2^8 - 1 = 255 |
| private static final int SHORT_MASK = (1 << Short.SIZE) - 1; // 2^16 - 1 = 65_535 |
| |
| @SuppressWarnings("unchecked") |
| static final ImmutableMap<Object, Object> EMPTY = |
| new RegularImmutableMap<>(null, new Object[0], 0); |
| |
| /* |
| * This is an implementation of ImmutableMap optimized especially for Android, which does not like |
| * objects per entry. Instead we use an open-addressed hash table. This design is basically |
| * equivalent to RegularImmutableSet, save that instead of having a hash table containing the |
| * elements directly and null for empty positions, we store indices of the keys in the hash table, |
| * and ABSENT for empty positions. We then look up the keys in alternatingKeysAndValues. |
| * |
| * (The index actually stored is the index of the key in alternatingKeysAndValues, which is |
| * double the index of the entry in entrySet.asList.) |
| * |
| * The basic data structure is described in https://en.wikipedia.org/wiki/Open_addressing. |
| * The pointer to a key is stored in hashTable[Hashing.smear(key.hashCode()) % table.length], |
| * save that if that location is already full, we try the next index, and the next, until we |
| * find an empty table position. Since the table has a power-of-two size, we use |
| * & (table.length - 1) instead of % table.length, though. |
| */ |
| |
| private final transient Object hashTable; |
| @VisibleForTesting final transient Object[] alternatingKeysAndValues; |
| private final transient int size; |
| |
| @SuppressWarnings("unchecked") |
| static <K, V> RegularImmutableMap<K, V> create(int n, Object[] alternatingKeysAndValues) { |
| if (n == 0) { |
| return (RegularImmutableMap<K, V>) EMPTY; |
| } else if (n == 1) { |
| checkEntryNotNull(alternatingKeysAndValues[0], alternatingKeysAndValues[1]); |
| return new RegularImmutableMap<K, V>(null, alternatingKeysAndValues, 1); |
| } |
| checkPositionIndex(n, alternatingKeysAndValues.length >> 1); |
| int tableSize = ImmutableSet.chooseTableSize(n); |
| Object hashTable = createHashTable(alternatingKeysAndValues, n, tableSize, 0); |
| return new RegularImmutableMap<K, V>(hashTable, alternatingKeysAndValues, n); |
| } |
| |
| /** |
| * Returns a hash table for the specified keys and values, and ensures that neither keys nor |
| * values are null. |
| */ |
| static Object createHashTable( |
| Object[] alternatingKeysAndValues, int n, int tableSize, int keyOffset) { |
| if (n == 1) { |
| // for n=1 we don't create a hash table, but we need to do the checkEntryNotNull check! |
| checkEntryNotNull( |
| alternatingKeysAndValues[keyOffset], alternatingKeysAndValues[keyOffset ^ 1]); |
| return null; |
| } |
| int mask = tableSize - 1; |
| if (tableSize <= BYTE_MAX_SIZE) { |
| /* |
| * Use 8 bits per entry. The value is unsigned to allow use up to a size of 2^8. |
| * |
| * The absent indicator of -1 signed becomes 2^8 - 1 unsigned, which reduces the actual max |
| * size to 2^8 - 1. However, due to a load factor < 1 the limit is never approached. |
| */ |
| byte[] hashTable = new byte[tableSize]; |
| Arrays.fill(hashTable, ABSENT); |
| |
| for (int i = 0; i < n; i++) { |
| int keyIndex = 2 * i + keyOffset; |
| Object key = alternatingKeysAndValues[keyIndex]; |
| Object value = alternatingKeysAndValues[keyIndex ^ 1]; |
| checkEntryNotNull(key, value); |
| for (int h = Hashing.smear(key.hashCode()); ; h++) { |
| h &= mask; |
| int previousKeyIndex = hashTable[h] & BYTE_MASK; // unsigned read |
| if (previousKeyIndex == BYTE_MASK) { // -1 signed becomes 255 unsigned |
| hashTable[h] = (byte) keyIndex; |
| break; |
| } else if (alternatingKeysAndValues[previousKeyIndex].equals(key)) { |
| throw duplicateKeyException(key, value, alternatingKeysAndValues, previousKeyIndex); |
| } |
| } |
| } |
| return hashTable; |
| } else if (tableSize <= SHORT_MAX_SIZE) { |
| /* |
| * Use 16 bits per entry. The value is unsigned to allow use up to a size of 2^16. |
| * |
| * The absent indicator of -1 signed becomes 2^16 - 1 unsigned, which reduces the actual max |
| * size to 2^16 - 1. However, due to a load factor < 1 the limit is never approached. |
| */ |
| short[] hashTable = new short[tableSize]; |
| Arrays.fill(hashTable, ABSENT); |
| |
| for (int i = 0; i < n; i++) { |
| int keyIndex = 2 * i + keyOffset; |
| Object key = alternatingKeysAndValues[keyIndex]; |
| Object value = alternatingKeysAndValues[keyIndex ^ 1]; |
| checkEntryNotNull(key, value); |
| for (int h = Hashing.smear(key.hashCode()); ; h++) { |
| h &= mask; |
| int previousKeyIndex = hashTable[h] & SHORT_MASK; // unsigned read |
| if (previousKeyIndex == SHORT_MASK) { // -1 signed becomes 65_535 unsigned |
| hashTable[h] = (short) keyIndex; |
| break; |
| } else if (alternatingKeysAndValues[previousKeyIndex].equals(key)) { |
| throw duplicateKeyException(key, value, alternatingKeysAndValues, previousKeyIndex); |
| } |
| } |
| } |
| return hashTable; |
| } else { |
| /* |
| * Use 32 bits per entry. |
| */ |
| int[] hashTable = new int[tableSize]; |
| Arrays.fill(hashTable, ABSENT); |
| |
| for (int i = 0; i < n; i++) { |
| int keyIndex = 2 * i + keyOffset; |
| Object key = alternatingKeysAndValues[keyIndex]; |
| Object value = alternatingKeysAndValues[keyIndex ^ 1]; |
| checkEntryNotNull(key, value); |
| for (int h = Hashing.smear(key.hashCode()); ; h++) { |
| h &= mask; |
| int previousKeyIndex = hashTable[h]; |
| if (previousKeyIndex == ABSENT) { |
| hashTable[h] = keyIndex; |
| break; |
| } else if (alternatingKeysAndValues[previousKeyIndex].equals(key)) { |
| throw duplicateKeyException(key, value, alternatingKeysAndValues, previousKeyIndex); |
| } |
| } |
| } |
| return hashTable; |
| } |
| } |
| |
| private static IllegalArgumentException duplicateKeyException( |
| Object key, Object value, Object[] alternatingKeysAndValues, int previousKeyIndex) { |
| return new IllegalArgumentException( |
| "Multiple entries with same key: " |
| + key |
| + "=" |
| + value |
| + " and " |
| + alternatingKeysAndValues[previousKeyIndex] |
| + "=" |
| + alternatingKeysAndValues[previousKeyIndex ^ 1]); |
| } |
| |
| private RegularImmutableMap(Object hashTable, Object[] alternatingKeysAndValues, int size) { |
| this.hashTable = hashTable; |
| this.alternatingKeysAndValues = alternatingKeysAndValues; |
| this.size = size; |
| } |
| |
| @Override |
| public int size() { |
| return size; |
| } |
| |
| @SuppressWarnings("unchecked") |
| @Override |
| @NullableDecl |
| public V get(@NullableDecl Object key) { |
| return (V) get(hashTable, alternatingKeysAndValues, size, 0, key); |
| } |
| |
| static Object get( |
| @NullableDecl Object hashTableObject, |
| @NullableDecl Object[] alternatingKeysAndValues, |
| int size, |
| int keyOffset, |
| @NullableDecl Object key) { |
| if (key == null) { |
| return null; |
| } else if (size == 1) { |
| return alternatingKeysAndValues[keyOffset].equals(key) |
| ? alternatingKeysAndValues[keyOffset ^ 1] |
| : null; |
| } else if (hashTableObject == null) { |
| return null; |
| } |
| if (hashTableObject instanceof byte[]) { |
| byte[] hashTable = (byte[]) hashTableObject; |
| int mask = hashTable.length - 1; |
| for (int h = Hashing.smear(key.hashCode()); ; h++) { |
| h &= mask; |
| int keyIndex = hashTable[h] & BYTE_MASK; // unsigned read |
| if (keyIndex == BYTE_MASK) { // -1 signed becomes 255 unsigned |
| return null; |
| } else if (alternatingKeysAndValues[keyIndex].equals(key)) { |
| return alternatingKeysAndValues[keyIndex ^ 1]; |
| } |
| } |
| } else if (hashTableObject instanceof short[]) { |
| short[] hashTable = (short[]) hashTableObject; |
| int mask = hashTable.length - 1; |
| for (int h = Hashing.smear(key.hashCode()); ; h++) { |
| h &= mask; |
| int keyIndex = hashTable[h] & SHORT_MASK; // unsigned read |
| if (keyIndex == SHORT_MASK) { // -1 signed becomes 65_535 unsigned |
| return null; |
| } else if (alternatingKeysAndValues[keyIndex].equals(key)) { |
| return alternatingKeysAndValues[keyIndex ^ 1]; |
| } |
| } |
| } else { |
| int[] hashTable = (int[]) hashTableObject; |
| int mask = hashTable.length - 1; |
| for (int h = Hashing.smear(key.hashCode()); ; h++) { |
| h &= mask; |
| int keyIndex = hashTable[h]; |
| if (keyIndex == ABSENT) { |
| return null; |
| } else if (alternatingKeysAndValues[keyIndex].equals(key)) { |
| return alternatingKeysAndValues[keyIndex ^ 1]; |
| } |
| } |
| } |
| } |
| |
| @Override |
| ImmutableSet<Entry<K, V>> createEntrySet() { |
| return new EntrySet<>(this, alternatingKeysAndValues, 0, size); |
| } |
| |
| static class EntrySet<K, V> extends ImmutableSet<Entry<K, V>> { |
| private final transient ImmutableMap<K, V> map; |
| private final transient Object[] alternatingKeysAndValues; |
| private final transient int keyOffset; |
| private final transient int size; |
| |
| EntrySet(ImmutableMap<K, V> map, Object[] alternatingKeysAndValues, int keyOffset, int size) { |
| this.map = map; |
| this.alternatingKeysAndValues = alternatingKeysAndValues; |
| this.keyOffset = keyOffset; |
| this.size = size; |
| } |
| |
| @Override |
| public UnmodifiableIterator<Entry<K, V>> iterator() { |
| return asList().iterator(); |
| } |
| |
| @Override |
| int copyIntoArray(Object[] dst, int offset) { |
| return asList().copyIntoArray(dst, offset); |
| } |
| |
| @Override |
| ImmutableList<Entry<K, V>> createAsList() { |
| return new ImmutableList<Entry<K, V>>() { |
| @Override |
| public Entry<K, V> get(int index) { |
| checkElementIndex(index, size); |
| @SuppressWarnings("unchecked") |
| K key = (K) alternatingKeysAndValues[2 * index + keyOffset]; |
| @SuppressWarnings("unchecked") |
| V value = (V) alternatingKeysAndValues[2 * index + (keyOffset ^ 1)]; |
| return new AbstractMap.SimpleImmutableEntry<K, V>(key, value); |
| } |
| |
| @Override |
| public int size() { |
| return size; |
| } |
| |
| @Override |
| public boolean isPartialView() { |
| return true; |
| } |
| }; |
| } |
| |
| @Override |
| public boolean contains(Object object) { |
| if (object instanceof Entry) { |
| Entry<?, ?> entry = (Entry<?, ?>) object; |
| Object k = entry.getKey(); |
| Object v = entry.getValue(); |
| return v != null && v.equals(map.get(k)); |
| } |
| return false; |
| } |
| |
| @Override |
| boolean isPartialView() { |
| return true; |
| } |
| |
| @Override |
| public int size() { |
| return size; |
| } |
| } |
| |
| @Override |
| ImmutableSet<K> createKeySet() { |
| @SuppressWarnings("unchecked") |
| ImmutableList<K> keyList = |
| (ImmutableList<K>) new KeysOrValuesAsList(alternatingKeysAndValues, 0, size); |
| return new KeySet<K>(this, keyList); |
| } |
| |
| static final class KeysOrValuesAsList extends ImmutableList<Object> { |
| private final transient Object[] alternatingKeysAndValues; |
| private final transient int offset; |
| private final transient int size; |
| |
| KeysOrValuesAsList(Object[] alternatingKeysAndValues, int offset, int size) { |
| this.alternatingKeysAndValues = alternatingKeysAndValues; |
| this.offset = offset; |
| this.size = size; |
| } |
| |
| @Override |
| public Object get(int index) { |
| checkElementIndex(index, size); |
| return alternatingKeysAndValues[2 * index + offset]; |
| } |
| |
| @Override |
| boolean isPartialView() { |
| return true; |
| } |
| |
| @Override |
| public int size() { |
| return size; |
| } |
| } |
| |
| static final class KeySet<K> extends ImmutableSet<K> { |
| private final transient ImmutableMap<K, ?> map; |
| private final transient ImmutableList<K> list; |
| |
| KeySet(ImmutableMap<K, ?> map, ImmutableList<K> list) { |
| this.map = map; |
| this.list = list; |
| } |
| |
| @Override |
| public UnmodifiableIterator<K> iterator() { |
| return asList().iterator(); |
| } |
| |
| @Override |
| int copyIntoArray(Object[] dst, int offset) { |
| return asList().copyIntoArray(dst, offset); |
| } |
| |
| @Override |
| public ImmutableList<K> asList() { |
| return list; |
| } |
| |
| @Override |
| public boolean contains(@NullableDecl Object object) { |
| return map.get(object) != null; |
| } |
| |
| @Override |
| boolean isPartialView() { |
| return true; |
| } |
| |
| @Override |
| public int size() { |
| return map.size(); |
| } |
| } |
| |
| @SuppressWarnings("unchecked") |
| @Override |
| ImmutableCollection<V> createValues() { |
| return (ImmutableList<V>) new KeysOrValuesAsList(alternatingKeysAndValues, 1, size); |
| } |
| |
| @Override |
| boolean isPartialView() { |
| return false; |
| } |
| |
| // This class is never actually serialized directly, but we have to make the |
| // warning go away (and suppressing would suppress for all nested classes too) |
| private static final long serialVersionUID = 0; |
| } |