如何使ConcurrentHashMap线程中的更新BigDecimal安全

Question

我正在制作一个需要一堆日记条目并计算总和的应用程序。

下面的方法是在有 多个线程 调用该addToSum()方法时是线程/并发安全的。我想确保每个电话都能正确更新总数。

如果不安全，请说明为确保线程安全我该怎么做。

我需要synchronize获取/放置还是有更好的方法？

private ConcurrentHashMap<String, BigDecimal> sumByAccount;

public void addToSum(String account, BigDecimal amount){
    BigDecimal newSum = sumByAccount.get(account).add(amount);
    sumByAccount.put(account, newSum);
}

非常感谢！

更新：

谢谢大家的回答，我已经知道上面的代码 不是线程安全的 。

感谢Vint建议AtomicReference使用替代synchronize。我以前AtomicInteger用来保存整数和，我想知道BigDecimal是否有类似的东西。

关于两者的利弊是否有定论？

Answer 1

您可以像其他建议的那样使用同步，但是如果需要最小限度的解决方案，则可以尝试AtomicReference作为BigDecimal的存储

ConcurrentHashMap<String,AtomicReference<BigDecimal>> map;

public void addToSum(String account, BigDecimal amount) {
    AtomicReference<BigDecimal> newSum = map.get(account);
    for (;;) {
       BigDecimal oldVal = newSum.get();
       if (newSum.compareAndSet(oldVal, oldVal.add(amount)))
            return;
    }
}

编辑-我将进一步解释：

AtomicReference使用CAS原子地分配单个引用。循环说明了这一点。

如果存储在AtomicReference中的当前字段== oldVal
[它们在内存中的位置，而不是它们的值]，则用替换存储在AtomicReference中的字段的值oldVal.add(amount)。现在，在for循环之后的任何时候，调用newSum.get（）都会有一个BigDecimal对象被添加到其中。

您想在此处使用循环，因为可能有两个线程试图将它们添加到同一AtomicReference中。可能发生一个线程成功而另一个线程失败的情况，如果发生这种情况，请尝试使用新增加的值。

如果线程争用程度适中，这将是更快的实现，而如果争用程度较高，则最好使用 synchronized