2

我正在通过调用add方法从多个线程填充我的番石榴缓存。现在从每 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 秒内再次填充，然后执行相同的过程？

我认为 usingcache.asMap()可能不是正确的方法，因为它不会清空缓存，所以它也会反映我的sendToDB方法中缓存上发生的所有更改？

4

1 回答 1

0

怎么样：

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

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

这种方法的一个缺点是它很活泼——有可能在创建快照之后但在调用之前将条目添加到缓存中.invalidateAll()，并且这些条目永远不会被发送到数据库。由于您的缓存也可能由于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。

于 2017-11-22T09:46:51.977 回答