如何从Guava LoadingCache中可靠地删除记录？

Question

public class MetricHolder {
  private final ExecutorService executor = Executors.newFixedThreadPool(2);
  private final LoadingCache<String, AtomicLongMap<String>> clientIdMetricCounterCache =
      CacheBuilder.newBuilder().expireAfterWrite(1, TimeUnit.MINUTES)
          .removalListener(RemovalListeners.asynchronous(new SendToDatabase(), executor))
          .build(new CacheLoader<String, AtomicLongMap<String>>() {
            @Override
            public AtomicLongMap<String> load(String key) throws Exception {
              return AtomicLongMap.create();
            }
          });

  private static class Holder {
    private static final MetricHolder INSTANCE = new MetricHolder();
  }

  public static MetricHolder getInstance() {
    return Holder.INSTANCE;
  }

  private MetricHolder() {}

  public void increment(String clientId, String name) throws ExecutionException {
    clientIdMetricCounterCache.get(clientId).incrementAndGet(name);
  }

  public LoadingCache<String, AtomicLongMap<String>> getClientIdMetricCounterCache() {
    return clientIdMetricCounterCache;
  }

  private static class SendToDatabase implements RemovalListener<String, AtomicLongMap<String>> {
    @Override
    public void onRemoval(RemovalNotification<String, AtomicLongMap<String>> notification) {
      String key = notification.getKey();
      AtomicLongMap<String> value = notification.getValue();
      System.out.println(key);
      System.out.println(value);
      // sending these key/value to some other system

    }
  }
}

那么expireafterwrite是如何工作的呢？它是否像调度程序一样工作，它每1分钟运行一次，删除ClientidMetricCounterCache中的所有条目，然后在1分钟后再次醒来，从同一个缓存中删除所有条目，并继续这样运行？看了维基之后，我怀疑它是那样工作的。如果没有，那么我如何能够可靠地每1分钟删除这些记录并发送到其他系统，因为我的写入可能在一段时间内很少？

看来我可能必须使用Guava TimeLimiter接口和SimpleTimeLimiter或ScheduledExecutorService来可靠地超时调用，然后删除条目？如果是，谁能提供一个例子，这将如何工作在我目前的例子？

Answer 1

对我来说，你似乎在滥用缓存，而地图可以做到这一点。您没有使用过期，没有大小限制，没有缓存，您只是收集统计数据。

您使用的唯一特性是加载方面，这并不值得。

我建议使用AtomicReference > :

null

它会比原来的方法产生更多的垃圾，但是所有的垃圾都是短暂的，所以您实际上可能会让GC更开心。

它很简单，不需要对库或其实现细节有很深的了解。

我想，volatile代替atomicreference也可以。