Package com.lmax.disruptor
Class SequenceGroup
java.lang.Object
com.lmax.disruptor.LhsPadding
com.lmax.disruptor.Value
com.lmax.disruptor.RhsPadding
com.lmax.disruptor.Sequence
com.lmax.disruptor.SequenceGroup
A
Sequence
group that can dynamically have Sequence
s added and removed while being
thread safe.
The get()
and set(long)
methods are lock free and can be
concurrently be called with the add(Sequence)
and remove(Sequence)
.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final AtomicReferenceFieldUpdater
<SequenceGroup, Sequence[]> private Sequence[]
Fields inherited from class com.lmax.disruptor.Sequence
INITIAL_VALUE
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
Add aSequence
into this aggregate.void
addWhileRunning
(Cursored cursored, Sequence sequence) Adds a sequence to the sequence group after threads have started to publish to the Disruptor.long
get()
Get the minimum sequence value for the group.boolean
Remove the first occurrence of theSequence
from this aggregate.void
set
(long value) Set allSequence
s in the group to a given value.int
size()
Get the size of the group.Methods inherited from class com.lmax.disruptor.Sequence
addAndGet, compareAndSet, incrementAndGet, setVolatile, toString
-
Field Details
-
SEQUENCE_UPDATER
-
sequences
-
-
Constructor Details
-
SequenceGroup
public SequenceGroup()Default Constructor
-
-
Method Details
-
get
public long get()Get the minimum sequence value for the group. -
set
public void set(long value) Set allSequence
s in the group to a given value. -
add
Add aSequence
into this aggregate. This should only be used during initialisation. UseaddWhileRunning(Cursored, Sequence)
- Parameters:
sequence
- to be added to the aggregate.- See Also:
-
remove
Remove the first occurrence of theSequence
from this aggregate.- Parameters:
sequence
- to be removed from this aggregate.- Returns:
- true if the sequence was removed otherwise false.
-
size
public int size()Get the size of the group.- Returns:
- the size of the group.
-
addWhileRunning
Adds a sequence to the sequence group after threads have started to publish to the Disruptor. It will set the sequences to cursor value of the ringBuffer just after adding them. This should prevent any nasty rewind/wrapping effects.- Parameters:
cursored
- The data structure that the owner of this sequence group will be pulling it's events from.sequence
- The sequence to add.
-