您可以像其他建议的那样使用同步,但是如果需要最小限度的解决方案,则可以尝试
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



