Package | Description |
---|---|
org.modeshape.common.collection.ring |
A ring buffer and the components it uses internally.
|
Modifier and Type | Class and Description |
---|---|
class |
TrailingPointer
|
Modifier and Type | Field and Description |
---|---|
protected Pointer |
SingleProducerCursor.current |
protected Pointer[] |
SingleProducerCursor.stayBehinds |
Modifier and Type | Method and Description |
---|---|
protected Pointer |
RingBuffer.ConsumerRunner.getPointer() |
Pointer |
SingleProducerCursor.newPointer() |
Pointer |
Cursor.newPointer()
Return a new pointer that starts at this cursor's current position, ensuring that this cursor always
stays behind it on the ring buffer. |
Modifier and Type | Method and Description |
---|---|
static <T> void |
Pointers.add(T holder,
AtomicReferenceFieldUpdater<T,Pointer[]> updater,
Cursor cursor,
Pointer... pointersToAdd)
Atomically add the specified
Pointer instance(s) to an array known to the given updator. |
static long |
Pointers.getMinimum(Pointer[] pointers,
long minimum) |
boolean |
TrailingPointer.ignore(Pointer pointer) |
boolean |
SingleProducerCursor.ignore(Pointer pointer) |
boolean |
GarbageCollectingConsumer.ignore(Pointer pointer) |
boolean |
DependentOnPointers.ignore(Pointer pointer)
Ignore the specified pointer that cursor had previously
stayed behind . |
static <T> boolean |
Pointers.remove(T holder,
AtomicReferenceFieldUpdater<T,Pointer[]> updater,
Pointer pointer)
Atomically remove the specified
Pointer instance from an array known to the given updator. |
void |
TrailingPointer.stayBehind(Pointer... pointers) |
void |
SingleProducerCursor.stayBehind(Pointer... pointers) |
void |
GarbageCollectingConsumer.stayBehind(Pointer... pointers) |
void |
DependentOnPointers.stayBehind(Pointer... pointers)
Ensure that this cursor always remains behind the specified pointer.
|
long |
WaitStrategy.waitFor(long position,
Pointer pointer,
Pointer dependentPointer,
PointerBarrier barrier)
Wait for the given position to be available.
|
long |
BlockingWaitStrategy.waitFor(long position,
Pointer pointer,
Pointer dependentPointer,
PointerBarrier barrier) |
Constructor and Description |
---|
GarbageCollectingConsumer(Cursor cursor,
Pointer cursorPointer,
WaitStrategy waitStrategy,
GarbageCollectingConsumer.Collectable collectable) |
TrailingPointer(long initialValue,
Pointer... stayBehinds) |
TrailingPointer(Pointer... stayBehinds) |
Copyright © 2008–2016 JBoss, a division of Red Hat. All rights reserved.