当 Guava Table 的支持映射是线程安全的时，它的线程安全吗？

Question

Guava 的 Tables.newCustomTable(Map, Supply) 方法在提供线程安全映射时返回线程安全表？例如：

public static <R, C, V> Table<R, C, V> newConcurrentTable() {
  return Tables.newCustomTable(
      new ConcurrentHashMap<R, Map<C, V>>(),
      new Supplier<Map<C, V>>() {
        public Map<C, V> get() {
          return new ConcurrentHashMap<C, V>();
        }
      });
}

该代码实际上返回并发表吗？

Answer 1

来自文档：“如果多个线程同时访问此表，并且其中一个线程修改了该表，则必须在外部进行同步。”

并发支持集合还不够。

Answer 2

凯文·伯里利恩是对的。您构造的映射不是线程安全的技术原因是，即使您使用的映射是线程安全的，表操作也可能不是。让我举一个 put 的例子，它是在 StandardTable 中实现的，它是由 Tables.newCustomTable 使用的：

public V put(R rowKey, C columnKey, V value) {
  Map<C, V> map = backingMap.get(rowKey);
  if (map == null) {
    map = factory.get();
    backingMap.put(rowKey, map);
  }
  return map.put(columnKey, value);
}

在处理 map = 时，线程安全受到损害。 = null 情况。也就是说，两个或多个线程可以进入该块并为 columnKey 创建一个新条目，最后一个执行 backingMap.put(rowKey, map) 最终将覆盖backingMap 中 columnKey 的条目，这会导致其他线程执行的 put 操作丢失。特别是在多线程环境下这个操作的结果是不确定的，相当于说这个操作不是线程安全的。

此方法的正确实现是：

public V put(R rowKey, C columnKey, V value) {
    ConcurrentMap<C, V> map = table.get(rowKey);
    if (map == null) {
        backingMap.putIfAbsent(rowKey, factory.get());
    }
    map = backingMap.get(rowKey);
    return map.put(columnKey, value);
}

我目前正在调查是否可以将 ForwardingTable 实现与您想要执行的操作一起使用，以获得正确的线程安全 ConcurrentTable。

但说实话，我认为 Table 没有线程安全实现的原因是接口本身不提供任何并发构造，例如 putIfAbsent 或替换。