在单例中进行适当的同步

Question

我有一个关于同步的问题。我有一个实例：

`

@Service
public class MyService {

   //if singleton - should this map be static?
   private static Map<String, String> cache = new ConcurrentHashMap<String, String>();

 public String put(String value) {
    if (!cache.containsKey(value)) {
       String newValue = someRandomString();
        cache.put(value, newValue);
        return newValue;
    }
    return cache.get(value);
 }

public String get(String value) {
   return cache.entrySet().stream()
  .filter(e -> e.getValue().equals(value))
  .map(Map.Entry::getKey)
  .findFirst().get();
}

} 

问题是 - 在单例和许多线程调用服务的情况下如何进行正确的同步。似乎这两种方法都受到影响，有时无法为相同的字符串值计算/放入映射中的适当数据。 ConcurrentHashMap 会被 SynchronizedMap 取代吗？我应该在这两种方法中创建一个同步块吗？

Answer 1

您的put() 方法不是原子的。试试这个：

public String put(String value) {
    return cache.computeIfAbsent(value, v -> someRandomString());
}

Answer 2

问题是 - 如何在以下情况下进行正确同步 单例和许多调用服务的线程。

您的同步范围需要涵盖整个逻辑操作，在这种情况下，它比内部Map 上的单个方法调用要广泛得多。因此，使用ConcurrentHashMap 或同步的Map 实现实际上并没有得到任何有用的东西，因为它们提供的关键区域的范围不够广泛。

对于您的特定示例，仅提供 put() 和 get() 方法，最简单的方法是简单地声明每个方法 synchronized。在这种情况下，您可以在内部使用普通的HashMap。例如，

public synchronized String put(String key) {
    // ...
}

public synchronized String get(String key) {
    // ...
}

这假设确实只有一个类的实例。如果有多个，那么同步这些方法是不够的。然而，据推测，每个实例都需要自己的映射，因此也需要将cache 更改为实例变量，这将与同步一起解决问题。就个人而言，我一开始就不会将 cache 设为静态。