Class TickRingBuffer

java.lang.Object

com.quantfinlib.marketdata.TickRingBuffer

public final class TickRingBuffer
extends Object

Zero-allocation single-producer / single-consumer ring buffer for market data ticks, in the style of the LMAX Disruptor:

• Preallocated primitive slots — ticks live in parallel int[]/double[]/long[] arrays; nothing is allocated per tick on either side, so the steady-state GC load is zero.
• Cache-line-padded sequences — head and tail counters are padded to avoid false sharing between the producer and consumer cores.
• Acquire/release ordering — slot writes are published with a single release store of the tail; no CAS, no locks on the hot path.
• Sequence caching — each side caches the other's sequence and only re-reads the volatile counter when it appears blocked, removing most cross-core traffic.

Constructor Summary

Constructors

Constructor	Description
TickRingBuffer(int requestedCapacity)

Method Summary

Modifier and Type	Method	Description
int	capacity()
int	drainTo(TickListener sink, int limit)	Consumer side; single consumer thread only.
boolean	isEmpty()
boolean	publish(int symbolId, double price, double size, long timestampNanos)	Producer side; single producer thread only.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TickRingBuffer

public TickRingBuffer(int requestedCapacity)

Parameters:

requestedCapacity - rounded up to the next power of two

Method Details

publish

public boolean publish(int symbolId,
 double price,
 double size,
 long timestampNanos)

Producer side; single producer thread only. Returns false when full — the caller chooses the backpressure policy (spin, drop, or count).

drainTo

public int drainTo(TickListener sink,
 int limit)

Consumer side; single consumer thread only. Drains up to limit ticks into the sink and returns how many were delivered.

isEmpty

public boolean isEmpty()

capacity

public int capacity()