同時ハッシュマップの同期ブロックを使用していますか？

Question

私の理解しているように、ConcurrentHashMapは、同時ハッシュマップ例外を取得することなく、複数のスレッドが同じハッシュマップ上で読み書きできるようにします（追加/削除）。

私は4つのスレッドを持ち、各スレッドはハッシュマップを更新できます。私は、現在のスレッドがそれを更新している間に他のスレッドがハッシュマップに書き込み/更新しないようにします。

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); 
        } 
       } 
      } 
     }); 
    } 

これは正しい方法ですか？同期ブロックがなければ、正しくない値が得られます。

Answer 1

はい、正しいです（マップが更新される唯一の場所であると仮定します）。マップの固有の非ブロッキング並行性に頼るのではなく、同期するため非効率です。

あなたが代わりにcompute()を使用する必要があります。

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

またはmerge()を：

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

Answer 2

てください、ユーザごとの長いカウンターを保存する簡単な場合には、それは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から始まることです。