src/jdk.jfr/share/classes/jdk/jfr/internal/LongMap.java
author mgronlun
Wed, 30 Oct 2019 19:43:52 +0100
changeset 58863 c16ac7a2eba4
parent 50113 src/jdk.jfr/share/classes/jdk/jfr/consumer/LongMap.java@caf115bb98ad
permissions -rw-r--r--
8226511: Implement JFR Event Streaming Reviewed-by: egahlin, mseledtsov, mgronlun Contributed-by: erik.gahlin@oracle.com, mikhailo.seledtsov@oracle.com, markus.gronlund@oracle.com
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     1
/*
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
     2
 * Copyright (c) 2019, Oracle and/or its affiliates. All rights reserved.
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     3
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     4
 *
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     5
 * This code is free software; you can redistribute it and/or modify it
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     6
 * under the terms of the GNU General Public License version 2 only, as
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     7
 * published by the Free Software Foundation.  Oracle designates this
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     8
 * particular file as subject to the "Classpath" exception as provided
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
     9
 * by Oracle in the LICENSE file that accompanied this code.
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    10
 *
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    11
 * This code is distributed in the hope that it will be useful, but WITHOUT
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    12
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    13
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    14
 * version 2 for more details (a copy is included in the LICENSE file that
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    15
 * accompanied this code).
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    16
 *
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    17
 * You should have received a copy of the GNU General Public License version
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    18
 * 2 along with this work; if not, write to the Free Software Foundation,
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    19
 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    20
 *
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    21
 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    22
 * or visit www.oracle.com if you need additional information or have any
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    23
 * questions.
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    24
 */
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    25
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    26
package jdk.jfr.internal;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    27
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    28
import java.util.BitSet;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    29
import java.util.function.Consumer;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    30
import java.util.function.LongConsumer;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    31
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    32
@SuppressWarnings("unchecked")
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    33
public final class LongMap<T> {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    34
    private static final int MAXIMUM_CAPACITY = 1 << 30;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    35
    private static final long[] EMPTY_KEYS = new long[0];
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    36
    private static final Object[] EMPTY_OBJECTS = new Object[0];
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    37
    private static final int DEFAULT_SIZE = 32;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    38
    private static final Object NULL_OBJECT = new Object();
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    39
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    40
    private final int bitCount;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    41
    private BitSet bitSet;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    42
    private long[] keys = EMPTY_KEYS;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    43
    private T[] objects = (T[]) EMPTY_OBJECTS;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    44
    private int count;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    45
    private int shift;
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    46
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    47
    public LongMap() {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    48
        this.bitCount = 0;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    49
    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    50
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    51
    public LongMap(int markBits) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    52
        this.bitCount = markBits;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    53
        this.bitSet = new BitSet();
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    54
    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    55
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    56
    // Should be 2^n
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    57
    private void initialize(int capacity) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    58
        keys = new long[capacity];
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    59
        objects = (T[]) new Object[capacity];
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    60
        shift = 64 - (31 - Integer.numberOfLeadingZeros(capacity));
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    61
    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    62
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    63
    public void claimBits() {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    64
        // flip last bit back and forth to make bitset expand to max size
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    65
        int lastBit = bitSetIndex(objects.length - 1, bitCount -1);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    66
        bitSet.flip(lastBit);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    67
        bitSet.flip(lastBit);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    68
    }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    69
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    70
    public void setId(long id, int bitIndex) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    71
        int bitSetIndex = bitSetIndex(tableIndexOf(id), bitIndex);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    72
        bitSet.set(bitSetIndex, true);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    73
    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    74
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    75
    public void clearId(long id, int bitIndex) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    76
        int bitSetIndex = bitSetIndex(tableIndexOf(id), bitIndex);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    77
        bitSet.set(bitSetIndex, false);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    78
    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    79
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    80
    public boolean isSetId(long id, int bitIndex) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    81
        int bitSetIndex = bitSetIndex(tableIndexOf(id), bitIndex);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    82
        return bitSet.get(bitSetIndex);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    83
    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    84
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    85
    private int bitSetIndex(int tableIndex, int bitIndex) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    86
        return bitCount * tableIndex + bitIndex;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    87
    }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
    88
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    89
    private int tableIndexOf(long id) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    90
        int index = index(id);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    91
        while (true) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    92
            if (objects[index] == null) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    93
                throw new InternalError("Unknown id");
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    94
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    95
            if (keys[index] == id) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    96
                return index;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    97
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    98
            index++;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
    99
            if (index == keys.length) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   100
                index = 0;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   101
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   102
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   103
    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   104
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   105
    public boolean hasKey(long id) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   106
        int index = index(id);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   107
        while (true) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   108
            if (objects[index] == null) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   109
               return false;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   110
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   111
            if (keys[index] == id) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   112
                return true;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   113
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   114
            index++;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   115
            if (index == keys.length) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   116
                index = 0;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   117
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   118
        }
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   119
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   120
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   121
    public void expand(int size) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   122
        int l = 4 * size / 3;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   123
        if (l <= keys.length) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   124
            return;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   125
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   126
        int n = tableSizeFor(l);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   127
        LongMap<T> temp = new LongMap<>(bitCount);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   128
        temp.initialize(n);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   129
        // Optimization, avoid growing while copying bits
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   130
        if (bitCount > 0 && !bitSet.isEmpty()) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   131
           temp.claimBits();
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   132
           claimBits();
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   133
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   134
        for (int tIndex = 0; tIndex < keys.length; tIndex++) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   135
            T o = objects[tIndex];
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   136
            if (o != null) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   137
                long key = keys[tIndex];
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   138
                temp.put(key, o);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   139
                if (bitCount != 0) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   140
                    for (int bIndex = 0; bIndex < bitCount; bIndex++) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   141
                        boolean bitValue = isSetId(key, bIndex);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   142
                        if (bitValue) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   143
                            temp.setId(key, bIndex);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   144
                        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   145
                    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   146
                }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   147
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   148
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   149
        keys = temp.keys;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   150
        objects = temp.objects;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   151
        shift = temp.shift;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   152
        bitSet = temp.bitSet;
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   153
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   154
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   155
    public void put(long id, T object) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   156
        if (keys == EMPTY_KEYS) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   157
            // Lazy initialization
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   158
            initialize(DEFAULT_SIZE);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   159
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   160
        if (object == null) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   161
            object = (T) NULL_OBJECT;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   162
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   163
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   164
        int index = index(id);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   165
        // probe for empty slot
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   166
        while (true) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   167
            if (objects[index] == null) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   168
                keys[index] = id;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   169
                objects[index] = object;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   170
                count++;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   171
                // Don't expand lazy since it
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   172
                // can cause resize when replacing
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   173
                // an object.
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   174
                if (count > 3 * keys.length / 4) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   175
                    expand(2 * keys.length);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   176
                }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   177
                return;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   178
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   179
            // if it already exists, replace
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   180
            if (keys[index] == id) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   181
                objects[index] = object;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   182
                return;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   183
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   184
            index++;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   185
            if (index == keys.length) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   186
                index = 0;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   187
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   188
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   189
    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   190
    public T getAt(int tableIndex) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   191
        T o =  objects[tableIndex];
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   192
        return o == NULL_OBJECT ? null : o;
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   193
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   194
58863
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   195
    public T get(long id) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   196
        if (keys == EMPTY_KEYS) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   197
            return null;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   198
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   199
        int index = index(id);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   200
        while (true) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   201
            if (objects[index] == null) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   202
                return null;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   203
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   204
            if (keys[index] == id) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   205
                return getAt(index);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   206
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   207
            index++;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   208
            if (index == keys.length) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   209
                index = 0;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   210
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   211
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   212
    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   213
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   214
    private int index(long id) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   215
        return (int) ((id * -7046029254386353131L) >>> shift);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   216
    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   217
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   218
    // Copied from HashMap::tableSizeFor
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   219
    private static final int tableSizeFor(int cap) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   220
        int n = -1 >>> Integer.numberOfLeadingZeros(cap - 1);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   221
        return (n < 0) ? 1 : (n >= MAXIMUM_CAPACITY) ? MAXIMUM_CAPACITY : n + 1;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   222
    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   223
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   224
    public void forEachKey(LongConsumer keyTraverser) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   225
        for (int i = 0; i < keys.length; i++) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   226
            if (objects[i] != null) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   227
                keyTraverser.accept(keys[i]);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   228
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   229
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   230
    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   231
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   232
    public void forEach(Consumer<T> consumer) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   233
        for (int i = 0; i < keys.length; i++) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   234
            T o = objects[i];
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   235
            if (o != null) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   236
                consumer.accept(o);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   237
            }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   238
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   239
    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   240
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   241
    public int size() {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   242
        return count;
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   243
    }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   244
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   245
    public String toString() {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   246
        StringBuilder sb = new StringBuilder();
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   247
        for (int i = 0; i < objects.length; i++) {
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   248
            sb.append(i);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   249
            sb.append(": id=");
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   250
            sb.append(keys[i]);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   251
            sb.append(" ");
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   252
            sb.append(objects[i]);
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   253
            sb.append("\n");
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   254
        }
c16ac7a2eba4 8226511: Implement JFR Event Streaming
mgronlun
parents: 50113
diff changeset
   255
        return sb.toString();
50113
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   256
    }
caf115bb98ad 8199712: Flight Recorder
egahlin
parents:
diff changeset
   257
}