conflation queues
--
efficient lock-free queues with a built-in safety mechanism to prevent overflow by the producer.See: Description
Interface | Description |
---|---|
AppenderListener<K,V> |
A listener for an
appender of a ConflationQueue for instance useful to
record performance metrics related to enqueue operations. |
ConflationQueue<K,V> |
A conflation queue is a queue with a safety mechanism to prevent overflow.
|
ConflationQueue.Appender<K,V> |
Appender used by the producer to enqueue values.
|
ConflationQueue.Poller<K,V> |
Poller object used by the consumer to poll values.
|
ConflationQueueBuilder<K,V> |
Builder for the different types of conflation queues serving as alternative to the queue constructors; a builder is
returned by the static methods of this interface.
|
ConflationQueueBuilder.ExchangeConflationQueueBuilder<K,V> |
Builder for
ExchangeConflationQueue subtypes. |
ConflationQueueBuilderImpl.CqFactory<K,V> |
Builder-internal factory for different types of conflation queues.
|
ExchangeConflationQueue<K,V> |
A conflation queue variant that allows exchanging of elements between the consumer and the producer.
|
ExchangeConflationQueue.ExchangePoller<K,V> |
Poller object used by the consumer to poll values; exchange poller adds functionality for exchanging values with
the producer during poll operations.
|
Merger<K,V> |
Merger strategy passed to some conflation queues upon construction to support merging of values when conflation
occurs.
|
PollerListener<K,V> |
A listener for an
poller of a ConflationQueue for instance useful to
record performance metrics related to poll operations. |
Class | Description |
---|---|
AtomicConflationQueue<K,V> |
A conflation queue implementation that atomically evicts old values from the queue if a new one is enqueued with the
same conflation key.
|
ConflationQueueBuilderImpl<K,V> |
Package local builder implementation as returned by the static methods of
ConflationQueueBuilder . |
ConflationQueueBuilderImpl.DeclaredKeysBuilder<K,V> |
Builder for the case that conflation keys are declared.
|
ConflationQueueBuilderImpl.DefaultBuilder<K,V> |
Default builder for the case that no conflation keys are declared.
|
ConflationQueueBuilderImpl.EntryMapFactoryBuilder<K,V> |
Builder for the case that an entry map factory has been provided.
|
ConflationQueueBuilderImpl.EnumKeyBuilder<K extends java.lang.Enum<K>,V> |
Builder for enum conflation key types.
|
Entry<K,V> |
Package local immutable wrapper object used by the queue implementations; holds conflation key and a value.
|
EvictConflationQueue<K,V> |
A conflation queue implementation that evicts old values from the queue if a new one is enqueued with the same
conflation key.
|
Factories |
Helper class dealing with unsafe casts necessary for factories of objects whose generic types are not known to the
factory provider.
|
MergeConflationQueue<K,V> |
A conflation queue implementation that merges old and new value if a value is enqueued and another one already exists
in the queue with the same conflation key.
|
Enum | Description |
---|---|
AppenderListener.Conflation |
The type of conflation that occurred when an element was enqueued.
|
conflation queues
--
efficient lock-free queues with a built-in safety mechanism to prevent overflow by the producer.