Interface | Description |
---|---|
RingBufferConsumerControl.ConsumerWaitStrategy |
This interface can be implemented to provide various custom wait strategies for the consumer side of the control.
|
RingBufferConsumerIterator.Consumer<R> |
Class | Description |
---|---|
RingBufferConsumerControl |
This code is substantially based on the ingenious work done by Martin Thompson
on what he calls "Mechanical Sympathy." It leans heavily on the source code
from version 3.0.0.beta2 of the LMAX-exchange Disruptor but has been completely
refactored in order to invert separate the control mechanism from what is being
controlled and to simplify the API.
|
RingBufferConsumerIterator<T> | |
RingBufferControl |
This code is substantially based on the ingenious work done by Martin Thompson on what he calls "Mechanical Sympathy." It leans heavily on the
source code from version 3.0.0.beta2 of the LMAX-exchange Disruptor but has been completely refactored in order to invert separate the control
mechanism from what is being controlled and to simplify the API.
|
RingBufferControlMulticaster |
This is a helper class for managing a set of
RingBufferControl s for use in a "single-publisher to multi-consumer" thread configuration
where everything published is "multicast" to all consumers. |
RingBufferControlMultiplexor |
This is a helper class for managing a set of
RingBufferControl s for use in a "multiple-publisher to single-consumer" thread configuration. |
RingBufferControlWorkerPool |
This is a helper class for managing a set of
RingBufferControl s for use in a "single-publisher to multi-consumer" thread configuration
where the consumers are workers reading from the queued data. |
Copyright © 2018. All rights reserved.