同步值，而不是对象

Question

我想在 Java 中做类似的事情，

  public void giveMoney(String userId, int money) {
    synchronized (userId) {

        Profile p = fetchProfileFromDB(userId);
        p.setMoney(p.getMoney() + userId);
        saveProfileToDB(p);

    }
   }

但是当然，在字符串上同步是不正确的。做这样的事情的正确方法是什么？

Answer 1

如果用户 ID 集有限，您可以在 String 的内部版本上进行同步。

使用 String.intern() （它有一些缺点）或类似 Guava Interners（如果您需要对实习进行更多控制）。

Answer 2

原则上，您可以在 Java 中的任何对象上进行同步。在 String 对象上进行同步本身并不是“不正确”；这取决于你到底在做什么。

但如果 userId 是方法中的局部变量，那么这将不起作用。执行该方法的每个线程都有自己的变量副本（可能为每个线程引用不同的 String 对象）；当然，线程之间的同步仅当您使多个线程在同一对象上同步时才有效。

您必须在包含具有 synchronized 块的方法的对象的成员变量上创建要同步的对象。如果多个线程随后调用同一对象上的方法，您将实现互斥。

class Something {
    private Object lock = new Object();

    public void someMethod() {
        synchronized (lock) {
            // ...
        }
    }
}

您还可以使用 java.util.concurrent.locks 包中的显式锁，如果您需要的话，它可以为您提供更多控制：

class Something {
    private Lock lock = new ReentrantLock();

    public void someMethod() {
        lock.lock();
        try {
            // ...
        } finally {
            lock.unlock();
        }
    }
}

特别是如果您想要一个用于写入的独占锁，但又不这样做如果希望线程在读取时必须相互等待，您可能需要使用ReadWriteLock。

Answer 3

我想有几个选择。

最简单的是，您可以将 userId 映射到线程安全映射中的锁对象。其他人提到了实习，但我认为这不是一个可行的选择。

然而，更常见的选项是在p（配置文件）上同步。如果 getProfile() 是线程安全的，那么这是合适的，并且根据其名称，我怀疑它可能是线程安全的。

Answer 4

从理论上讲，由于 interned 对象可以进行 GC，因此可以在不同时间同步不同对象（具有相同值）。互斥性仍然得到保证，因为不可能同时在不同对象上进行同步。

但是，如果我们在不同的对象上进行同步，则发生之前的关系就存在疑问。我们必须检查实施情况才能找到答案。而且由于它涉及 GC，而 Java 内存模型没有解决这一问题，因此推理可能相当困难。

这是理论上的反对意见。实际上我认为这不会造成任何问题。

尽管如此，仍然可以有简单、直接且理论上正确的解决方案来解决您的问题。例如简单的基于Java名称的锁？

Answer 5

您可以使用字符串的代理对象。

Object userIdMutex = new Object();

synchronized (userIdMutex) {
    Profile p = getProfile(userId);
    p.setMoney(p.getMoney() + p);
    saveProfile(p);
}

每当您访问 userId 时，请使用此互斥锁。

Answer 6

根据您的示例，我假设您想要获取配置文件类的锁，更改它，然后释放锁。我认为同步并不完全是您所需要的。您需要一个类来管理这些记录，并允许您在需要对其进行更改时锁定和解锁记录，即源代码控制样式。

看看这个： 锁定Java 5 类

Answer 7

怎么样：

String userId = ...;
Object userIdLock = new Object();
synchronized (userIdLock) {
    Profile p = getProfile(userId);
    p.setMoney(p.getMoney() + p);
    saveProfile(p);
}

它很简单，而且显而易见。