java - 如何将Guava缓存发送到另一种方法时每30秒清空一次？

Question

我通过调用add方法从多个线程填充我的 Guava 缓存。现在，从每30秒运行一次的后台线程中，我想将缓存中的所有内容原子地发送给sendToDB方法吗？

下面是我的代码:

public class Example {
  private final ScheduledExecutorService executorService = Executors
      .newSingleThreadScheduledExecutor();
  private final Cache<Integer, List<Process>> cache = CacheBuilder.newBuilder().maximumSize(100000)
      .removalListener(RemovalListeners.asynchronous(new CustomRemovalListener(), executorService))
      .build();

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

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

  private Example() {
    executorService.scheduleAtFixedRate(new Runnable() {
      @Override
      public void run() {
        // is this the right way to send cache map?
        sendToDB(cache.asMap());
      }
    }, 0, 30, SECONDS);
  }

  // this method will be called from multiple threads
  public void add(final int id, final Process process) {
    // add id and process into cache
  }

  // this will only be called from single background thread
  private void sendToDB(ConcurrentMap<Integer, List<Process>> holder) {
    // use holder here

  }
}

这是将 cache映射发送到我的 sendToDB方法的正确方法吗？基本上，我要发送缓存中存在的所有条目，持续30秒钟，然后清空缓存。之后，我的缓存将在接下来的30秒内再次填充，然后执行相同的过程？

我认为使用 cache.asMap()可能不是正确的方法，因为它不会清空缓存，因此它也将反射(reflect)我 sendToDB方法中缓存上发生的所有更改吗？

Answer 1

怎么样:

@Override
public void run() {
  ImmutableMap<Integer, List<Process>> snapshot = ImmutableMap.copyOf(cache.asMap());
  cache.invalidateAll();
  sendToDB(snapshot);
}

这会将缓存的内容复制到新的映射中，从而在特定时间点创建缓存的快照。然后 .invalidateAll()将清空缓存，然后将快照发送到数据库。

这种方法的一个缺点是它的灵活性-可能在创建快照之后但在调用 .invalidateAll()之前将条目添加到缓存中，并且此类条目永远不会发送到DB。由于您的缓存也可能由于 maximumSize()设置而驱逐条目，因此我认为这不是问题，但是如果是这样，则希望在构造快照时删除条目，如下所示:

@Override
public void run() {
  Iterator<Entry<Integer, List<Process>> iter = cache.asMap().entrySet().iterator();
  ImmutableMap<Integer, List<Process>> builder = ImmutableMap.builder();
  while (iter.hasNext()) {
    builder.add(iter.next());
    iter.remove();
  }
  sendToDB(builder.build());
}

通过这种方法，当调用 cache时 sendToDB()可能实际上不是空的，但是快照开始之前存在的每个条目都将被删除并发送到数据库。

或者，您可以创建一个具有 Cache字段的包装器类，并自动将该字段替换为新的空缓存，然后将旧缓存的内容复制到数据库中并进行GC。