putIfAbsent와 함께 "get/check/put"을 사용하십시오.

Question

저는 Cassandra와 Datastax Java 드라이버를 사용하고 있습니다. 준비된 문장을 캐싱하여 다시 사용하려고합니다. 내 위의 getStatement 방법은 여러 스레드에 의해 호출됩니다

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

    public BoundStatement getStatement(String cql) { 
    Session session = TestUtils.getInstance().getSession(); 
    PreparedStatement ps = holder.get(cql); 
    // no statement is cached, create one and cache it now. 
    if (ps == null) { 
     synchronized (this) { 
     ps = holder.get(cql); 
     if (ps == null) { 
      ps = session.prepare(cql); 
      holder.put(cql, ps); 
     } 
     } 
    } 
    return ps.bind(); 
    } 

그래서 그것이 스레드 안전 확인해야합니다. Java 7에서 작동하므로 불행히도 computeIfAbsent을 사용할 수 없습니다.

static anaylysis 툴에 대해 코드를 실행했을 때 Java 7에서 코드를 작성하는 더 좋은 방법이 있다고 생각하게하는 사소한 경고가있었습니다.

Might be better to replace use of get/check/put with putIfAbsent 

업데이트 : 그 하나 개의 스레드가 같은 준비된 문장을 만들려고하지 않는 경우에도 다른 차단할 수를 제외하고

public BoundStatement getStatement(String cql) { 
    Session session = TestUtils.getInstance().getSession(); 
    PreparedStatement ps = holder.get(cql); 
    // no statement is cached, create one and cache it now. 
    if (ps == null) { 
     ps = session.prepare(cql); 
     PreparedStatement old = holder.putIfAbsent(cql, ps); 
     if (old!=null) 
     ps=old; 
    } 
    return ps.bind(); 
    } 

Answer 1

그것은, 당신이 그것을 가지고 너무 나쁘지 않다.

Java 8에서 computeIfAbsent을 사용하면 훨씬 더 좋습니다. 자바 7에서는이 작업을 수행 할 수 있습니다

ps = holder.get(cql); 
if (ps == null) { 
    ps = session.prepare(cql); 
    PreparedStatement old = holder.putIfAbsent(cql, ps); 
    if (old!=null) 
    ps=old; 
} 

두 스레드가 동시에 같은 일을 만들려고하는 경우가 가끔 있지만 캐시를 사용하지 않는 단지 동등의 최악의 경우, 불필요한 PreparedStatement로 만들 것 . 당신은 구아바 라이브러리를 사용할 수 있는지

또는 다음 구아바 LoadingCache은 당신이 원하는 정확히 무엇을 : https://google.github.io/guava/releases/16.0/api/docs/com/google/common/cache/CacheBuilder.html