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 | 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)
|
static <E> RingBuffer<E> |
RingBuffer.createMultiProducer(EventFactory<E> factory,
int bufferSize) |
Create a new multiple producer RingBuffer using the default wait strategy
BlockingWaitStrategy . |
static <E> RingBuffer<E> |
RingBuffer.createMultiProducer(EventFactory<E> factory,
int bufferSize,
WaitStrategy waitStrategy) |
Create a new multiple producer RingBuffer with the specified wait strategy.
|
static <E> RingBuffer<E> |
RingBuffer.createSingleProducer(EventFactory<E> factory,
int bufferSize) |
Create a new single producer RingBuffer using the default wait strategy
BlockingWaitStrategy . |
static <E> RingBuffer<E> |
RingBuffer.createSingleProducer(EventFactory<E> factory,
int bufferSize,
WaitStrategy waitStrategy) |
Create a new single producer RingBuffer with the specified wait strategy.
|
Constructor | Description |
---|---|
WorkerPool(EventFactory<T> eventFactory,
ExceptionHandler<? super T> exceptionHandler,
WorkHandler<? super T>... workHandlers) |
Construct a work pool with an internal
RingBuffer for convenience. |
Constructor | Description |
---|---|
Disruptor(EventFactory<T> eventFactory,
int ringBufferSize,
Executor executor) |
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,
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,
ThreadFactory threadFactory) |
Create a new Disruptor.
|
Disruptor(EventFactory<T> eventFactory,
int ringBufferSize,
ThreadFactory threadFactory,
ProducerType producerType,
WaitStrategy waitStrategy) |
Create a new Disruptor.
|
Copyright © 2019. All rights reserved.