com.hazelcast.internal.metrics.managementcenter

Class ConcurrentArrayRingbuffer<E>

java.lang.Object

com.hazelcast.internal.metrics.managementcenter.ConcurrentArrayRingbuffer<E>

public class ConcurrentArrayRingbuffer<E>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ConcurrentArrayRingbuffer.RingbufferSlice<E>

Constructor Summary

Constructors

Constructor and Description
ConcurrentArrayRingbuffer(int capacity)

Method Summary

Modifier and Type	Method and Description
void	add(E item) Appends an item to the ring buffer.
void	clear()
ConcurrentArrayRingbuffer.RingbufferSlice<E>	copyFrom(long sequence) Copies all the items from the given sequence up to the tail.
E	get(long sequence)
int	getCapacity()
boolean	isEmpty()
long	size()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConcurrentArrayRingbuffer

public ConcurrentArrayRingbuffer(int capacity)

Method Detail

add

public void add(E item)

Appends an item to the ring buffer. If size == capacity, also drops the oldest item.

clear

public void clear()

get

public E get(long sequence)

copyFrom

public ConcurrentArrayRingbuffer.RingbufferSlice<E> copyFrom(long sequence)

Copies all the items from the given sequence up to the tail. If the item at the sequence number is already dropped, start from the oldest item.

Throws:

IllegalArgumentException - If the sequence is in the future.

getCapacity

public int getCapacity()

size

public long size()

isEmpty

public boolean isEmpty()