Package com.helix.experiments.benchmarks

Class DisruptorStreamingBenchmark

java.lang.Object
com.helix.experiments.benchmarks.DisruptorStreamingBenchmark
Direct Known Subclasses:
DisruptorStreamingBenchmark_jmhType_B1
public class DisruptorStreamingBenchmark extends Object
JMH Microbenchmark suite measuring sustained ring buffer streaming throughput (>1,500,000 events/sec) and latency percentiles (P50, P99) with LMAX Disruptor.

  • Field Details

  • Constructor Details

    • DisruptorStreamingBenchmark

      public DisruptorStreamingBenchmark()

  • Method Details

    • setup

      public void setup() throws Exception
      Throws:
      Exception

    • tearDown

      public void tearDown()

    • benchmarkSustainedThroughput

      public void benchmarkSustainedThroughput()
      Measures sustained zero-allocation streaming throughput (events/second). Target: >1,500,000 events/sec.

    • benchmarkRingBufferLatency

      public void benchmarkRingBufferLatency()
      Measures ring buffer publication latency percentiles (P50, P99).

    • benchmarkRoundTripLatency

      public StreamResult benchmarkRoundTripLatency()
      Measures synchronous end-to-end event completion latency percentiles (P50, P99).

    • getBridge

      public DisruptorStreamBridge getBridge()