我正在缓存准备好的语句，以便在使用DataStaxJava驱动程序（cassandra）时不必再次准备它。。下面是我的代码，它可以工作：

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

  public ResultSetFuture send(final String cql, final Object... values) {
    return executeWithSession(new SessionCallable<ResultSetFuture>() {
      @Override
      public ResultSetFuture executeWithSession(Session session) {
        BoundStatement bs = getStatement(cql, values);
        bs.setConsistencyLevel(consistencyLevel);
        return session.executeAsync(bs);
      }
    });
  }

  private BoundStatement getStatement(final String cql, final Object... values) {
    Session session = getSession();
    PreparedStatement ps = cache.get(cql);
    // no statement cached, create one and cache it now.
    // below line is causing thread safety issue..
    if (ps == null) {
      ps = session.prepare(cql);
      PreparedStatement old = cache.putIfAbsent(cql, ps);
      if (old != null)
        ps = old;
    }
    return ps.bind(values);
  }

但问题是 send 方法将由多个线程调用，因此我怀疑 getStatement 方法不是线程安全的，因为 if (ps == null) 检查。。我怎样才能保证线程安全？
我想避免使用 synchronize 所以我想看看有没有更好的办法。我现在正在使用Java7。