|
Falcon
|
#include <ringbuffer.hpp>
Public Member Functions | |
| RingBuffer (const T &prototype, int buffer_size, disruptor::ClaimStrategyOption claim_strategy_option, disruptor::WaitStrategyOption wait_strategy_option) | |
| T * | Get (const int64_t &sequence) |
this RingBuffer implementation is based on the disruptor::RingBuffer but it stores the data objects in a vector
Ring based store of reusable entries containing the data representing an event being exchanged between publisher and EventProcessors.
| <T> | implementation storing the data for sharing during exchange or parallel coordination of an event. |
|
inline |
Construct a RingBuffer with the full option set.
| prototype | of data object to store in ring buffer |
| buffer_size | of the RingBuffer, must be a power of 2. |
| claim_strategy_option | threading strategy for publishers claiming entries in the ring. |
| wait_strategy_option | waiting strategy employed by processors_to_track waiting in entries becoming available. |
|
inline |
Get the event for a given sequence in the RingBuffer.
| sequence | for the event |