今天突然發(fā)現線上對 Kafka 消費者的監(jiān)控出了問題，經過排查發(fā)現是在多線程的情況下使用了 HashMap 進行讀寫，下面來詳細分析一下丟數據的原因。

首先寫一個 demo ，模擬線上問題

public class Main {

    private static Map<Integer, String> map = new HashMap<>(32);

    static ExecutorService exec = Executors.newFixedThreadPool(10);

    public static void main(String[] args) throws InterruptedException {
        for (int i = 1; i <= 10; i++) {
            int finalI = i;
            exec.submit(() -> {
                map.put(finalI, "test:" + finalI);
            });
        }
        TimeUnit.SECONDS.sleep(1);
        System.out.println(map);
    }
    
}

運行幾次后會發(fā)現打印出了不正常的結果

{2=test:2, 3=test:3, 4=test:4, 5=test:5, 6=test:6, 7=test:7, 8=test:8, 9=test:9, 10=test:10}

我在初始化時設置初始容量為32，所以不會有擴容的問題，下面我們從源碼找一找問題，首先我看一下 table 這個字段的解釋

    /**
     * The table, initialized on first use, and resized as
     * necessary. When allocated, length is always a power of two.
     * (We also tolerate length zero in some operations to allow
     * bootstrapping mechanics that are currently not needed.)
     */
    transient Node<K,V>[] table;

大體意思就是在第一次使用時進行初始化，然后會進行 resize ，下面看一下 put 調用的 putVal 中的幾行代碼

if ((tab = table) == null || (n = tab.length) == 0)
    n = (tab = resize()).length;

從這里我們可以發(fā)現在第一次調用 put 時會調用 resize ，下面看一下resize中的部分代碼

    if (oldCap > 0) {
            if (oldCap >= MAXIMUM_CAPACITY) {
                threshold = Integer.MAX_VALUE;
                return oldTab;
            }
            else if ((newCap = oldCap << 1) < MAXIMUM_CAPACITY &&
                     oldCap >= DEFAULT_INITIAL_CAPACITY)
                newThr = oldThr << 1; // double threshold
        }
        else if (oldThr > 0) // initial capacity was placed in threshold
            newCap = oldThr;
        else {               // zero initial threshold signifies using defaults
            newCap = DEFAULT_INITIAL_CAPACITY;
            newThr = (int)(DEFAULT_LOAD_FACTOR * DEFAULT_INITIAL_CAPACITY);
        }
        threshold = newThr;
        @SuppressWarnings({"rawtypes","unchecked"})
            Node<K,V>[] newTab = (Node<K,V>[])new Node[newCap];
        table = newTab;
        if (oldTab != null) {
                // 一些復制操作
        }
        return newTab;

可以看出第一次調用 put 時會走到else中，對容量和閾值進行初始化，初始化完畢后我們可以看到，返回了一個新的table，這里在多線程環(huán)境下就會導致數據丟失的問題，所以如果我們要在多線程環(huán)境下使用map的話，還是推薦使用 ConcurrentHashMap 的。