in core/src/main/java/com/spotify/metrics/core/OverwritingFixedConcurrentRingBuffer.java [45:56]
public OverwritingFixedConcurrentRingBuffer(final T sentinel, final int capacity) {
if (capacity <= 0) {
throw new IllegalArgumentException(
"capacity must be a positive integer but was: " + capacity);
}
this.buffer = new AtomicReferenceArray<>(capacity);
this.capacity = capacity;
for (int i = 0; i < capacity; i++) {
buffer.set(i, sentinel);
}
}