Dependencies
Declarations
-
com
-
lmax
-
disruptor
-
AbstractSequencer
-
bufferSize: int
-
waitStrategy: WaitStrategy
-
cursor: Sequence
-
gatingSequences: Sequence[]
-
SEQUENCE_UPDATER: AtomicReferenceFieldUpdater<AbstractSequencer, Sequence[]>
-
AbstractSequencer(int, WaitStrategy): void
-
getCursor(): long
-
getBufferSize(): int
-
addGatingSequences(Sequence[]): void
-
removeGatingSequence(Sequence): boolean
-
getMinimumSequence(): long
-
newBarrier(Sequence[]): SequenceBarrier
-
newPoller(DataProvider<Object>, Sequence[]): EventPoller<Object>
-
toString(): String
-
-
AggregateEventHandler
-
AlertException
-
BatchEventProcessor
-
IDLE: int
-
HALTED: int
-
RUNNING: int
-
running: AtomicInteger
-
exceptionHandler: ExceptionHandler<Object>
-
dataProvider: DataProvider<Object>
-
sequenceBarrier: SequenceBarrier
-
eventHandler: EventHandler<Object>
-
sequence: Sequence
-
timeoutHandler: TimeoutHandler
-
batchStartAware: BatchStartAware
-
BatchEventProcessor(DataProvider<Object>, SequenceBarrier, EventHandler<Object>): void
-
getSequence(): Sequence
-
halt(): void
-
isRunning(): boolean
-
setExceptionHandler(ExceptionHandler<Object>): void
-
run(): void
-
processEvents(): void
-
earlyExit(): void
-
notifyTimeout(long): void
-
notifyStart(): void
-
notifyShutdown(): void
-
-
BatchStartAware
-
BlockingWaitStrategy
-
BusySpinWaitStrategy
-
Cursored
-
DataProvider
-
EventFactory
-
EventHandler
-
EventPoller
-
dataProvider: DataProvider<Object>
-
sequencer: Sequencer
-
sequence: Sequence
-
gatingSequence: Sequence
-
Handler
-
PollState
-
EventPoller(DataProvider<Object>, Sequencer, Sequence, Sequence): void
-
poll(Handler<Object>): PollState
-
newInstance(DataProvider<Object>, Sequencer, Sequence, Sequence, Sequence[]): EventPoller<Object>
-
getSequence(): Sequence
-
-
EventProcessor
-
EventReleaseAware
-
EventReleaser
-
EventSequencer
-
EventSink
-
publishEvent(EventTranslator<Object>): void
-
tryPublishEvent(EventTranslator<Object>): boolean
-
publishEvent(EventTranslatorOneArg<Object, Object>, Object): void
-
tryPublishEvent(EventTranslatorOneArg<Object, Object>, Object): boolean
-
publishEvent(EventTranslatorTwoArg<Object, Object, Object>, Object, Object): void
-
tryPublishEvent(EventTranslatorTwoArg<Object, Object, Object>, Object, Object): boolean
-
publishEvent(EventTranslatorThreeArg<Object, Object, Object, Object>, Object, Object, Object): void
-
tryPublishEvent(EventTranslatorThreeArg<Object, Object, Object, Object>, Object, Object, Object): boolean
-
publishEvent(EventTranslatorVararg<Object>, Object[]): void
-
tryPublishEvent(EventTranslatorVararg<Object>, Object[]): boolean
-
publishEvents(EventTranslator[]): void
-
publishEvents(EventTranslator[], int, int): void
-
tryPublishEvents(EventTranslator[]): boolean
-
tryPublishEvents(EventTranslator[], int, int): boolean
-
publishEvents(EventTranslatorOneArg<Object, Object>, Object[]): void
-
publishEvents(EventTranslatorOneArg<Object, Object>, int, int, Object[]): void
-
tryPublishEvents(EventTranslatorOneArg<Object, Object>, Object[]): boolean
-
tryPublishEvents(EventTranslatorOneArg<Object, Object>, int, int, Object[]): boolean
-
publishEvents(EventTranslatorTwoArg<Object, Object, Object>, Object[], Object[]): void
-
publishEvents(EventTranslatorTwoArg<Object, Object, Object>, int, int, Object[], Object[]): void
-
tryPublishEvents(EventTranslatorTwoArg<Object, Object, Object>, Object[], Object[]): boolean
-
tryPublishEvents(EventTranslatorTwoArg<Object, Object, Object>, int, int, Object[], Object[]): boolean
-
publishEvents(EventTranslatorThreeArg<Object, Object, Object, Object>, Object[], Object[], Object[]): void
-
publishEvents(EventTranslatorThreeArg<Object, Object, Object, Object>, int, int, Object[], Object[], Object[]): void
-
tryPublishEvents(EventTranslatorThreeArg<Object, Object, Object, Object>, Object[], Object[], Object[]): boolean
-
tryPublishEvents(EventTranslatorThreeArg<Object, Object, Object, Object>, int, int, Object[], Object[], Object[]): boolean
-
publishEvents(EventTranslatorVararg<Object>, Object[][]): void
-
publishEvents(EventTranslatorVararg<Object>, int, int, Object[][]): void
-
tryPublishEvents(EventTranslatorVararg<Object>, Object[][]): boolean
-
tryPublishEvents(EventTranslatorVararg<Object>, int, int, Object[][]): boolean
-
-
EventTranslator
-
EventTranslatorOneArg
-
EventTranslatorThreeArg
-
EventTranslatorTwoArg
-
EventTranslatorVararg
-
ExceptionHandler
-
FatalExceptionHandler
-
FixedSequenceGroup
-
IgnoreExceptionHandler
-
InsufficientCapacityException
-
LifecycleAware
-
LiteBlockingWaitStrategy
-
LiteTimeoutBlockingWaitStrategy
-
MultiProducerSequencer
-
calculateIndex(long): int
-
UNSAFE: Unsafe
-
BASE: long
-
SCALE: long
-
gatingSequenceCache: Sequence
-
availableBuffer: int[]
-
indexMask: int
-
indexShift: int
-
MultiProducerSequencer(int, WaitStrategy): void
-
hasAvailableCapacity(int): boolean
-
hasAvailableCapacity(Sequence[], int, long): boolean
-
claim(long): void
-
next(): long
-
next(int): long
-
tryNext(): long
-
tryNext(int): long
-
remainingCapacity(): long
-
initialiseAvailableBuffer(): void
-
publish(long): void
-
publish(long, long): void
-
setAvailable(long): void
-
setAvailableBufferValue(int, int): void
-
isAvailable(long): boolean
-
getHighestPublishedSequence(long, long): long
-
calculateAvailabilityFlag(long): int
-
-
NoOpEventProcessor
-
PhasedBackoffWaitStrategy
-
SPIN_TRIES: int
-
spinTimeoutNanos: long
-
yieldTimeoutNanos: long
-
fallbackStrategy: WaitStrategy
-
PhasedBackoffWaitStrategy(long, long, TimeUnit, WaitStrategy): void
-
withLock(long, long, TimeUnit): PhasedBackoffWaitStrategy
-
withLiteLock(long, long, TimeUnit): PhasedBackoffWaitStrategy
-
withSleep(long, long, TimeUnit): PhasedBackoffWaitStrategy
-
waitFor(long, Sequence, Sequence, SequenceBarrier): long
-
signalAllWhenBlocking(): void
-
-
ProcessingSequenceBarrier
-
waitStrategy: WaitStrategy
-
dependentSequence: Sequence
-
alerted: boolean
-
cursorSequence: Sequence
-
sequencer: Sequencer
-
ProcessingSequenceBarrier(Sequencer, WaitStrategy, Sequence, Sequence[]): void
-
waitFor(long): long
-
getCursor(): long
-
isAlerted(): boolean
-
alert(): void
-
clearAlert(): void
-
checkAlert(): void
-
-
RingBufferFields
-
RingBufferPad
-
RingBuffer
-
p2: long
-
p3: long
-
p4: long
-
p5: long
-
p6: long
-
p7: long
-
INITIAL_CURSOR_VALUE: long
-
p1: long
-
RingBuffer(EventFactory<Object>, Sequencer): void
-
createMultiProducer(EventFactory<Object>, int, WaitStrategy): RingBuffer<Object>
-
createMultiProducer(EventFactory<Object>, int): RingBuffer<Object>
-
createSingleProducer(EventFactory<Object>, int, WaitStrategy): RingBuffer<Object>
-
createSingleProducer(EventFactory<Object>, int): RingBuffer<Object>
-
create(ProducerType, EventFactory<Object>, int, WaitStrategy): RingBuffer<Object>
-
get(long): Object
-
next(): long
-
next(int): long
-
tryNext(): long
-
tryNext(int): long
-
resetTo(long): void
-
claimAndGetPreallocated(long): Object
-
isPublished(long): boolean
-
addGatingSequences(Sequence[]): void
-
getMinimumGatingSequence(): long
-
removeGatingSequence(Sequence): boolean
-
newBarrier(Sequence[]): SequenceBarrier
-
newPoller(Sequence[]): EventPoller<Object>
-
getCursor(): long
-
getBufferSize(): int
-
hasAvailableCapacity(int): boolean
-
publishEvent(EventTranslator<Object>): void
-
tryPublishEvent(EventTranslator<Object>): boolean
-
publishEvent(EventTranslatorOneArg<Object, Object>, Object): void
-
tryPublishEvent(EventTranslatorOneArg<Object, Object>, Object): boolean
-
publishEvent(EventTranslatorTwoArg<Object, Object, Object>, Object, Object): void
-
tryPublishEvent(EventTranslatorTwoArg<Object, Object, Object>, Object, Object): boolean
-
publishEvent(EventTranslatorThreeArg<Object, Object, Object, Object>, Object, Object, Object): void
-
tryPublishEvent(EventTranslatorThreeArg<Object, Object, Object, Object>, Object, Object, Object): boolean
-
publishEvent(EventTranslatorVararg<Object>, Object[]): void
-
tryPublishEvent(EventTranslatorVararg<Object>, Object[]): boolean
-
publishEvents(EventTranslator[]): void
-
publishEvents(EventTranslator[], int, int): void
-
tryPublishEvents(EventTranslator[]): boolean
-
tryPublishEvents(EventTranslator[], int, int): boolean
-
publishEvents(EventTranslatorOneArg<Object, Object>, Object[]): void
-
publishEvents(EventTranslatorOneArg<Object, Object>, int, int, Object[]): void
-
tryPublishEvents(EventTranslatorOneArg<Object, Object>, Object[]): boolean
-
tryPublishEvents(EventTranslatorOneArg<Object, Object>, int, int, Object[]): boolean
-
publishEvents(EventTranslatorTwoArg<Object, Object, Object>, Object[], Object[]): void
-
publishEvents(EventTranslatorTwoArg<Object, Object, Object>, int, int, Object[], Object[]): void
-
tryPublishEvents(EventTranslatorTwoArg<Object, Object, Object>, Object[], Object[]): boolean
-
tryPublishEvents(EventTranslatorTwoArg<Object, Object, Object>, int, int, Object[], Object[]): boolean
-
publishEvents(EventTranslatorThreeArg<Object, Object, Object, Object>, Object[], Object[], Object[]): void
-
publishEvents(EventTranslatorThreeArg<Object, Object, Object, Object>, int, int, Object[], Object[], Object[]): void
-
tryPublishEvents(EventTranslatorThreeArg<Object, Object, Object, Object>, Object[], Object[], Object[]): boolean
-
tryPublishEvents(EventTranslatorThreeArg<Object, Object, Object, Object>, int, int, Object[], Object[], Object[]): boolean
-
publishEvents(EventTranslatorVararg<Object>, Object[][]): void
-
publishEvents(EventTranslatorVararg<Object>, int, int, Object[][]): void
-
tryPublishEvents(EventTranslatorVararg<Object>, Object[][]): boolean
-
tryPublishEvents(EventTranslatorVararg<Object>, int, int, Object[][]): boolean
-
publish(long): void
-
publish(long, long): void
-
remainingCapacity(): long
-
checkBounds(EventTranslator[], int, int): void
-
checkBatchSizing(int, int): void
-
checkBounds(Object[], int, int): void
-
checkBounds(Object[], Object[], int, int): void
-
checkBounds(Object[], Object[], Object[], int, int): void
-
checkBounds(int, int, Object[][]): void
-
batchOverRuns(Object[], int, int): void
-
translateAndPublish(EventTranslator<Object>, long): void
-
translateAndPublish(EventTranslatorOneArg<Object, Object>, long, Object): void
-
translateAndPublish(EventTranslatorTwoArg<Object, Object, Object>, long, Object, Object): void
-
translateAndPublish(EventTranslatorThreeArg<Object, Object, Object, Object>, long, Object, Object, Object): void
-
translateAndPublish(EventTranslatorVararg<Object>, long, Object[]): void
-
translateAndPublishBatch(EventTranslator[], int, int, long): void
-
translateAndPublishBatch(EventTranslatorOneArg<Object, Object>, Object[], int, int, long): void
-
translateAndPublishBatch(EventTranslatorTwoArg<Object, Object, Object>, Object[], Object[], int, int, long): void
-
translateAndPublishBatch(EventTranslatorThreeArg<Object, Object, Object, Object>, Object[], Object[], Object[], int, int, long): void
-
translateAndPublishBatch(EventTranslatorVararg<Object>, int, int, long, Object[][]): void
-
toString(): String
-
-
LhsPadding
-
Value
-
RhsPadding
-
Sequence
-
SequenceBarrier
-
SequenceGroup
-
SequenceGroups
-
SequenceReportingEventHandler
-
Sequenced
-
Sequencer
-
INITIAL_CURSOR_VALUE: long
-
claim(long): void
-
isAvailable(long): boolean
-
addGatingSequences(Sequence[]): void
-
removeGatingSequence(Sequence): boolean
-
newBarrier(Sequence[]): SequenceBarrier
-
getMinimumSequence(): long
-
getHighestPublishedSequence(long, long): long
-
newPoller(DataProvider<Object>, Sequence[]): EventPoller<Object>
-
-
SingleProducerSequencerPad
-
SingleProducerSequencerFields
-
SingleProducerSequencer
-
p1: long
-
p2: long
-
p3: long
-
p4: long
-
p5: long
-
p6: long
-
p7: long
-
SingleProducerSequencer(int, WaitStrategy): void
-
hasAvailableCapacity(int): boolean
-
hasAvailableCapacity(int, boolean): boolean
-
next(): long
-
next(int): long
-
tryNext(): long
-
tryNext(int): long
-
remainingCapacity(): long
-
claim(long): void
-
publish(long): void
-
publish(long, long): void
-
isAvailable(long): boolean
-
getHighestPublishedSequence(long, long): long
-
-
SleepingWaitStrategy
-
DEFAULT_RETRIES: int
-
DEFAULT_SLEEP: long
-
retries: int
-
sleepTimeNs: long
-
SleepingWaitStrategy(): void
-
SleepingWaitStrategy(int): void
-
SleepingWaitStrategy(int, long): void
-
waitFor(long, Sequence, Sequence, SequenceBarrier): long
-
signalAllWhenBlocking(): void
-
applyWaitMethod(SequenceBarrier, int): int
-
-
TimeoutBlockingWaitStrategy
-
TimeoutException
-
TimeoutHandler
-
WaitStrategy
-
WorkHandler
-
WorkProcessor
-
timeoutHandler: TimeoutHandler
-
notifyShutdown(): void
-
running: AtomicBoolean
-
sequence: Sequence
-
ringBuffer: RingBuffer<Object>
-
sequenceBarrier: SequenceBarrier
-
workHandler: WorkHandler<Object>
-
exceptionHandler: ExceptionHandler<Object>
-
workSequence: Sequence
-
eventReleaser: EventReleaser
-
WorkProcessor(RingBuffer<Object>, SequenceBarrier, WorkHandler<Object>, ExceptionHandler<Object>, Sequence): void
-
getSequence(): Sequence
-
halt(): void
-
isRunning(): boolean
-
run(): void
-
notifyTimeout(long): void
-
notifyStart(): void
-
-
WorkerPool
-
started: AtomicBoolean
-
workSequence: Sequence
-
ringBuffer: RingBuffer<Object>
-
workProcessors: WorkProcessor[]
-
WorkerPool(RingBuffer<Object>, SequenceBarrier, ExceptionHandler<Object>, WorkHandler[]): void
-
WorkerPool(EventFactory<Object>, ExceptionHandler<Object>, WorkHandler[]): void
-
getWorkerSequences(): Sequence[]
-
start(Executor): RingBuffer<Object>
-
drainAndHalt(): void
-
halt(): void
-
isRunning(): boolean
-
-
YieldingWaitStrategy
-
dsl
-
BasicExecutor
-
ConsumerInfo
-
ConsumerRepository
-
eventProcessorInfoByEventHandler: Map<EventHandler<Object>, EventProcessorInfo<Object>>
-
eventProcessorInfoBySequence: Map<Sequence, ConsumerInfo>
-
consumerInfos: Collection<ConsumerInfo>
-
add(EventProcessor, EventHandler<Object>, SequenceBarrier): void
-
add(EventProcessor): void
-
add(WorkerPool<Object>, SequenceBarrier): void
-
getLastSequenceInChain(boolean): Sequence[]
-
getEventProcessorFor(EventHandler<Object>): EventProcessor
-
getSequenceFor(EventHandler<Object>): Sequence
-
unMarkEventProcessorsAsEndOfChain(Sequence[]): void
-
iterator(): Iterator<ConsumerInfo>
-
getBarrierFor(EventHandler<Object>): SequenceBarrier
-
getEventProcessorInfo(EventHandler<Object>): EventProcessorInfo<Object>
-
getEventProcessorInfo(Sequence): ConsumerInfo
-
-
Disruptor
-
checkNotStarted(): void
-
checkOnlyStartedOnce(): void
-
ringBuffer: RingBuffer<Object>
-
executor: Executor
-
consumerRepository: ConsumerRepository<Object>
-
started: AtomicBoolean
-
exceptionHandler: ExceptionHandler<Object>
-
Disruptor(EventFactory<Object>, int, Executor): void
-
Disruptor(EventFactory<Object>, int, Executor, ProducerType, WaitStrategy): void
-
Disruptor(EventFactory<Object>, int, ThreadFactory): void
-
Disruptor(EventFactory<Object>, int, ThreadFactory, ProducerType, WaitStrategy): void
-
Disruptor(RingBuffer<Object>, Executor): void
-
handleEventsWith(EventHandler[]): EventHandlerGroup<Object>
-
handleEventsWith(EventProcessorFactory[]): EventHandlerGroup<Object>
-
toString(): String
-
handleEventsWith(EventProcessor[]): EventHandlerGroup<Object>
-
handleEventsWithWorkerPool(WorkHandler[]): EventHandlerGroup<Object>
-
handleExceptionsWith(ExceptionHandler<Object>): void
-
setDefaultExceptionHandler(ExceptionHandler<Object>): void
-
handleExceptionsFor(EventHandler<Object>): ExceptionHandlerSetting<Object>
-
after(EventHandler[]): EventHandlerGroup<Object>
-
after(EventProcessor[]): EventHandlerGroup<Object>
-
publishEvent(EventTranslator<Object>): void
-
publishEvent(EventTranslatorOneArg<Object, Object>, Object): void
-
publishEvents(EventTranslatorOneArg<Object, Object>, Object[]): void
-
publishEvent(EventTranslatorTwoArg<Object, Object, Object>, Object, Object): void
-
publishEvent(EventTranslatorThreeArg<Object, Object, Object, Object>, Object, Object, Object): void
-
start(): RingBuffer<Object>
-
halt(): void
-
shutdown(): void
-
shutdown(long, TimeUnit): void
-
getRingBuffer(): RingBuffer<Object>
-
getCursor(): long
-
getBufferSize(): long
-
get(long): Object
-
getBarrierFor(EventHandler<Object>): SequenceBarrier
-
getSequenceValueFor(EventHandler<Object>): long
-
hasBacklog(): boolean
-
createEventProcessors(Sequence[], EventHandler[]): EventHandlerGroup<Object>
-
updateGatingSequencesForNextInChain(Sequence[], Sequence[]): void
-
createEventProcessors(Sequence[], EventProcessorFactory[]): EventHandlerGroup<Object>
-
createWorkerPool(Sequence[], WorkHandler[]): EventHandlerGroup<Object>
-
-
EventHandlerGroup
-
disruptor: Disruptor<Object>
-
consumerRepository: ConsumerRepository<Object>
-
sequences: Sequence[]
-
EventHandlerGroup(Disruptor<Object>, ConsumerRepository<Object>, Sequence[]): void
-
and(EventHandlerGroup<Object>): EventHandlerGroup<Object>
-
and(EventProcessor[]): EventHandlerGroup<Object>
-
then(EventHandler[]): EventHandlerGroup<Object>
-
then(EventProcessorFactory[]): EventHandlerGroup<Object>
-
thenHandleEventsWithWorkerPool(WorkHandler[]): EventHandlerGroup<Object>
-
handleEventsWith(EventHandler[]): EventHandlerGroup<Object>
-
handleEventsWith(EventProcessorFactory[]): EventHandlerGroup<Object>
-
handleEventsWithWorkerPool(WorkHandler[]): EventHandlerGroup<Object>
-
asSequenceBarrier(): SequenceBarrier
-
-
EventProcessorFactory
-
EventProcessorInfo
-
eventprocessor: EventProcessor
-
handler: EventHandler<Object>
-
barrier: SequenceBarrier
-
endOfChain: boolean
-
EventProcessorInfo(EventProcessor, EventHandler<Object>, SequenceBarrier): void
-
getEventProcessor(): EventProcessor
-
getSequences(): Sequence[]
-
getHandler(): EventHandler<Object>
-
getBarrier(): SequenceBarrier
-
isEndOfChain(): boolean
-
start(Executor): void
-
halt(): void
-
markAsUsedInBarrier(): void
-
isRunning(): boolean
-
-
ExceptionHandlerSetting
-
ExceptionHandlerWrapper
-
ProducerType
-
WorkerPoolInfo
-
workerPool: WorkerPool<Object>
-
sequenceBarrier: SequenceBarrier
-
endOfChain: boolean
-
WorkerPoolInfo(WorkerPool<Object>, SequenceBarrier): void
-
getSequences(): Sequence[]
-
getBarrier(): SequenceBarrier
-
isEndOfChain(): boolean
-
start(Executor): void
-
halt(): void
-
markAsUsedInBarrier(): void
-
isRunning(): boolean
-
-
-
util
-
-
-
Java files
com/lmax/disruptor/
Class files