From 3f13d12faef132a8202cb9d8bc713e98ef84b498 Mon Sep 17 00:00:00 2001
From: Keshava Munegowda <keshava.gowda@gmail.com>
Date: Mon, 3 Jun 2024 19:13:31 +0530
Subject: [PATCH] Add throughput mode for JMH benchmarking.

Signed-off-by: Keshava Munegowda <keshava.gowda@gmail.com>
---
 .../jmh/java/io/perl/benchmark/QueueBenchmark.java   | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/perl/src/jmh/java/io/perl/benchmark/QueueBenchmark.java b/perl/src/jmh/java/io/perl/benchmark/QueueBenchmark.java
index d3ec7cbc..326418ec 100644
--- a/perl/src/jmh/java/io/perl/benchmark/QueueBenchmark.java
+++ b/perl/src/jmh/java/io/perl/benchmark/QueueBenchmark.java
@@ -14,8 +14,10 @@
 import io.perl.api.impl.CQueue;
 import io.perl.api.impl.SyncQueue;
 import org.openjdk.jmh.annotations.Benchmark;
+import org.openjdk.jmh.annotations.BenchmarkMode;
 import org.openjdk.jmh.annotations.Fork;
 import org.openjdk.jmh.annotations.Measurement;
+import org.openjdk.jmh.annotations.Mode;
 import org.openjdk.jmh.annotations.Scope;
 import org.openjdk.jmh.annotations.State;
 import org.openjdk.jmh.annotations.Threads;
@@ -53,6 +55,7 @@ public QueueBenchmark() {
     @Timeout(time = 60)
     @Warmup(iterations = 0)
     @Measurement(iterations = 3)
+    @BenchmarkMode(Mode.Throughput)
     public void cqueueBenchmark() {
         cqueue.add(1);
         cqueue.poll();
@@ -63,6 +66,7 @@ public void cqueueBenchmark() {
     @Timeout(time = 60)
     @Warmup(iterations = 0)
     @Measurement(iterations = 3)
+    @BenchmarkMode(Mode.Throughput)
     public void concurrentQueueBenchmark() {
         clinkedQueue.add(1);
         clinkedQueue.poll();
@@ -73,6 +77,7 @@ public void concurrentQueueBenchmark() {
     @Timeout(time = 60)
     @Warmup(iterations = 0)
     @Measurement(iterations = 3)
+    @BenchmarkMode(Mode.Throughput)
     public void linkedBlockingQueueBenchmark() {
         linkedbq.add(1);
         linkedbq.poll();
@@ -83,6 +88,7 @@ public void linkedBlockingQueueBenchmark() {
     @Timeout(time = 60)
     @Warmup(iterations = 0)
     @Measurement(iterations = 3)
+    @BenchmarkMode(Mode.Throughput)
     public void atomicQueueBenchmark() {
         atomicQueue.add(1);
         atomicQueue.poll();
@@ -94,6 +100,7 @@ public void atomicQueueBenchmark() {
     @Timeout(time = 60)
     @Warmup(iterations = 0)
     @Measurement(iterations = 3)
+    @BenchmarkMode(Mode.Throughput)
     public void syncQueueBenchmark() {
         syncQueue.add(1);
         syncQueue.poll();
@@ -105,6 +112,7 @@ public void syncQueueBenchmark() {
     @Timeout(time = 60)
     @Warmup(iterations = 0)
     @Measurement(iterations = 3)
+    @BenchmarkMode(Mode.Throughput)
     @Threads(10)
     public void cqueueMultiThreadBenchmark() {
         cqueue.add(10);
@@ -116,6 +124,7 @@ public void cqueueMultiThreadBenchmark() {
     @Timeout(time = 60)
     @Warmup(iterations = 0)
     @Measurement(iterations = 3)
+    @BenchmarkMode(Mode.Throughput)
     @Threads(10)
     public void concurrentQueueMultiThreadBenchmark() {
         clinkedQueue.add(10);
@@ -127,6 +136,7 @@ public void concurrentQueueMultiThreadBenchmark() {
     @Timeout(time = 60)
     @Warmup(iterations = 0)
     @Measurement(iterations = 3)
+    @BenchmarkMode(Mode.Throughput)
     @Threads(10)
     public void linkedBlockingQueueMultiThreadBenchmark() {
         linkedbq.add(10);
@@ -138,6 +148,7 @@ public void linkedBlockingQueueMultiThreadBenchmark() {
     @Timeout(time = 60)
     @Warmup(iterations = 0)
     @Measurement(iterations = 3)
+    @BenchmarkMode(Mode.Throughput)
     @Threads(10)
     public void atomicQueueMultiThreadBenchmark() {
         atomicQueue.add(10);
@@ -149,6 +160,7 @@ public void atomicQueueMultiThreadBenchmark() {
     @Timeout(time = 60)
     @Warmup(iterations = 0)
     @Measurement(iterations = 3)
+    @BenchmarkMode(Mode.Throughput)
     @Threads(10)
     public void syncQueueMultiThreadBenchmark() {
         syncQueue.add(10);