Package | Description |
---|---|
com.lmax.disruptor |
The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
|
com.lmax.disruptor.dsl |
Modifier and Type | Method and Description |
---|---|
static <E> RingBuffer<E> |
RingBuffer.create(ProducerType producerType,
EventFactory<E> factory,
int bufferSize,
WaitStrategy waitStrategy)
Create a new Ring Buffer with the specified producer type (SINGLE or MULTI)
|
Modifier and Type | Method and Description |
---|---|
static ProducerType |
ProducerType.valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static ProducerType[] |
ProducerType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Constructor and Description |
---|
Disruptor(EventFactory<T> eventFactory,
int ringBufferSize,
java.util.concurrent.Executor executor,
ProducerType producerType,
WaitStrategy waitStrategy)
Deprecated.
Use a
ThreadFactory instead of an Executor as a the ThreadFactory
is able to report errors when it is unable to construct a thread to run a producer. |
Disruptor(EventFactory<T> eventFactory,
int ringBufferSize,
java.util.concurrent.ThreadFactory threadFactory,
ProducerType producerType,
WaitStrategy waitStrategy)
Create a new Disruptor.
|