并发 HashMap 不以线程安全方式运行 [重复]

Question

我有一个 CHM

private ConcurrentHashMap<Integer,Integer>pR = new ConcurrentHashMap<>();

我有一个增加其值的方法

public void incrementPR(int count){

        Integer value = this.pR.get(count);
       if(value == null){
           this.pR.put(count,1);
       } else {
           this.pR.put(count,value+1);
       }
    }

如果我触发 500 个并发请求，则使用 jmeter 从端点调用此方法，哈希映射孔的值不是 500，而是 437、430 等，它的行为不是线程安全的，我们如何实现线程安全性

Answer 1

您在某些语句中破坏了“获取当前值”、“递增”和“将其保存回地图”。现在，当这些语句同时运行时，您会得到连线结果。您的失败与并发地图无关。您应该为您的代码使用一些并发控制机制（如信号量、锁......）。有关更多信息，请参阅此问题： Java Concurrency Incrementing a Value

如果您对有效的解决方案（不使用锁定机制）感兴趣，您可以使用AtomicInteger：

AtomicInteger atomicInteger = new AtomicInteger();
//when you want to add your number, use this code
atomicInteger.getAndAdd(1);

但是，如果您对此语句的负载很重，则使用 AtomicLong 可能会成为瓶颈（因为它使用比较和交换 cpu 指令）。在这种情况下，最好使用LongAdder：

LongAdder longAdder = new LongAdder();
//when you want to add your number, use this code
longAdder.increment()

Answer 2

当一个类被描述为“线程安全”时，通常意味着该类将确保对其方法的并发调用之间有足够的排除性，以维护类的完整性（和相关的不变量）。

这并不意味着它将确保另一个类不能在调用之间修改它。

在您的情况下，如果一个线程调用 this.pR.get(count); ，然后另一个线程在调用 put 之前调用它，那么它们将在竞争中更新对象，并且看起来“丢失”计数。

您需要围绕对incrementPR 的调用进行一些同步。

在这种情况下，简单明了的答案是：

public synchronized void incrementPR(int count){
    //....
}

事实上，在那里同步可能没有必要使用同步地图。从提供的 sn-p 中并不清楚。