正在使用同步哈希映射的同步块是否正确？

根据我的理解，ConcurrentHashMap将允许多个线程在同一散列映射上读写（添加/删除），而不会出现并发散列映射异常。正在使用同步哈希映射的同步块是否正确？

我有4个线程，每个线程可以更新散列表。我不希望其他线程在当前线程正在更新时在hashmap上写/更新。

ConcurrentHashMap<String, Integer> playerLoginCounterHashMap = new ConcurrentHashMap<>(); 

    ExecutorService executorService = Executors.newFixedThreadPool(4); 

    for (int i = 0; i < 4; i++) { 

     executorService.submit(new Runnable() { 
      @Override 
      public void run() { 
       synchronized (playerLoginCounterHashMap) { 
        if (playerLoginCounterHashMap.get("testPlayer") == null) { 
         playerLoginCounterHashMap.put("testPlayer", 1); 
        } else { 
         playerLoginCounterHashMap.put("testPlayer", playerLoginCounterHashMap.get("testPlayer").intValue() + 1); 
        } 
       } 
      } 
     }); 
    }

这是正确的做法吗？没有同步块我得到的值是不正确的。

来源

2017-08-28 forum.test17

该代码为您生成一个异常？ –

您需要使用'putIfAbsent'或'computeIfAbsent'等并发感知API来允许并发。否则，如果您的整个更新过程需要是原子的，那么唯一的解决方案就是在更新时锁定并阻止任何其他线程使用映射，此时ConcurrentHashMap不会为您添加任何值。 –

@DanielPryden putIfAbsent，虽然 –

是的，它是正确的（假设这是地图更新的唯一地方），但效率不高，因为它同步而不是依赖于地图固有的非阻塞并发。

您应该使用compute()代替：

playerLoginCounterHashMap.compute(
    "testPlayer", 
    (key, value) -> value == null ? 1 : value + 1);

或者merge()：

playerLoginCounterHashMap.merge(
    "testPlayer", 
    1, 
    Integer::sum);

来源

2017-08-28 12:51:28

请注意，存储每个用户的长柜台的简单的情况下，它可能是有意义的使用Google Guava AtomicLongMap ：

final AtomicLongMap<String> loginCounterByPlayerName = AtomicLongMap.create(); 
final ExecutorService executorService = Executors.newFixedThreadPool(4); 
for (int i = 0; i < 4; i++) { 
    executorService.submit(new Runnable() { 
     @Override 
     public void run() { 
      loginCounterByPlayerName.addAndGet("testPlayer", 1); 
     } 
    }); 
}

唯一不同事情是，计数器从0开始。

来源

2017-08-28 13:04:04 yegodm

正在使用同步哈希映射的同步块是否正确？

回答

相关问题