ConcurrentHashMap：避免使用“ putIfAbsent”创建额外的对象？

Question

我正在多线程环境中聚合键的多个值。密钥未知。我以为我会做这样的事情：

class Aggregator {
    protected ConcurrentHashMap<String, List<String>> entries =
                            new ConcurrentHashMap<String, List<String>>();
    public Aggregator() {}

    public void record(String key, String value) {
        List<String> newList =
                    Collections.synchronizedList(new ArrayList<String>());
        List<String> existingList = entries.putIfAbsent(key, newList);
        List<String> values = existingList == null ? newList : existingList;
        values.add(value);
    }
}

我看到的问题是，每次运行此方法时，我都需要创建一个新的实例，ArrayList然后将其丢弃（在大多数情况下）。这似乎是对垃圾收集器的不合理滥用。是否有更好的，线程安全的方法来初始化这种结构而不必使用synchronize该record方法？我对使该putIfAbsent方法不返回新创建的元素的决定感到惊讶，并且对缺少除非被要求（可以这么说）实例化实例的延迟的方法感到惊讶。

Answer 1

Java 8引入了一个API来解决这个确切的问题，提出了一种1行解决方案：

public void record(String key, String value) {
    entries.computeIfAbsent(key, k -> Collections.synchronizedList(new ArrayList<String>())).add(value);
}

对于Java 7：

public void record(String key, String value) {
    List<String> values = entries.get(key);
    if (values == null) {
        entries.putIfAbsent(key, Collections.synchronizedList(new ArrayList<String>()));
        // At this point, there will definitely be a list for the key.
        // We don't know or care which thread's new object is in there, so:
        values = entries.get(key);
    }
    values.add(value);
}

这是填充时的标准代码模式ConcurrentHashMap。

特殊方法putIfAbsent(K, V))将放入您的值对象，或者如果在您之前有另一个线程，那么它将忽略您的值对象。无论哪种方式，都确保在调用之后putIfAbsent(K, V))，get(key)线程之间保持一致，因此上述代码是线程安全的。

唯一浪费的开销是，如果其他某个线程在同一时间为同一键同时添加新条目：您 可能 最终 会 丢弃新创建的值，但这只会在尚无条目 且
存在种族冲突的情况下发生线程丢失，这种情况通常很少见。