アトミック操作としてgetとputを使用して並行ハッシュマップスレッドを安全にする方法はありますか？

Question

私の下のメソッドのスレッドは安全ですか？このメソッドはSingletonクラスです。

private static final Map<String, PreparedStatement> holder = new ConcurrentHashMap<>(); 

    public BoundStatement getStatement(String cql) { 
    Session session = TestUtils.getInstance().getSession(); 
    PreparedStatement ps = holder.get(cql); 
    if(ps == null) { // If "ps" is already present in cache, then we don't have to synchronize and make threads wait. 
     synchronized { 
      ps = holder.get(cql); 
      if (ps == null) { 
      ps = session.prepare(cql); 
      holder.put(cql, ps); 
      } 
     } 
    } 
    return ps.bind(); 
    } 

私はカサンドラと協力しdatastax Javaドライバを使用して、私は準備された文を再利用していると私はここでそれをキャッシュしています理由ですしています。 Prepared StatementおよびBoundStatement。

私のgetStatementメソッドはスレッドセーフであれば（スレッドセーフであれば）、そのようなsynchronizedブロックを使用するより良い方法はありますか？これらの操作のスレッドセーフな他のデータ構造ですか？私は.putIfAbsentはJava7であるので、あなたがそれを使用できるJava 7

Answer 1

で働いています：putIfAbsentはまだ内部的に同じ同期を使用しています

private static final ConcurrentHashMap<String, PreparedStatement> holder = new ConcurrentHashMap<>(); 

    public BoundStatement getStatement(String cql) { 
    Session session = TestUtils.getInstance().getSession(); 
    PreparedStatement ps = holder.get(cql); 
    if(ps == null) { // If "ps" is already present in cache, then we don't have to synchronize and make threads wait. 

     if (holder.putIfAbsent(cql, session.prepare(cql)) != null) { 
      // Someone else got there before, handle 
     } 
    } 
    return ps.bind(); 
    } 

注意。

Answer 2

memoizationを行う場合は、Java 7で最も簡単に実行できます。Guavaには、使用できるコンピューティングのCache実装があり、Mapインターフェイスには、Java 8にはcomputeIfAbsentメソッドがありますしかし、あなたは明らかにここで不運です。

アレクシーの回答のように、空のレースにオブジェクトを作成することができれば、それが最適な解決策です。できない場合、実装はスレッドセーフであり、合理的です。

これは二重チェックロックの形式ですが、この実装ではCHMのputとgetのメソッドを使用して先発順序を保証しています。