java - 如何包装 ConcurrentSkipListSet 以线程安全的方式保持最新值的固定容量？

Question

我想包装 ConcurrentSkipListSet保持最新的固定容量(根据 Comparator )值:

private int capacity = 100;
// using Integer just for an illustration
private ConcurrentSkipListSet<Integer> intSet = new ConcurrentSkipListSet<>();

因此，我这样实现put():

// This method should be atomic.
public void put(int value) {
    intSet.add(value);
    if (intSet.size() > capacity)
        intSet.pollFirst();
}

但是，这个put() 不是线程安全的。

注意:没有其他变异方法。当然，我需要像 getLast() 或 getBefore(Integer value) 这样的“只读”方法。

How to wrap ConcurrentSkipListSet to keep a fixed capacity of the latest values in a thread-safe way?

Answer 1

您不太可能能够做到这一点并获得 ConcurrentSkipListSet 的并发优势。到那时，您还不如使用 Collections.synchronizedNavigableSet(TreeSet)，此时您只需编写

synchronized (set) {
  set.add(value);
  if (set.size() > cap) {
    set.pollFirst();
  }
}