You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2023/05/11 15:39:13 UTC
[camel-performance-tests] 03/04: (chores) performance: use the average time for the seda and disruptor tests
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git
commit de535783ae469dc5b1f9e75ac5c28377c96537be
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Thu May 11 12:05:39 2023 +0200
(chores) performance: use the average time for the seda and disruptor tests
This makes it easier to evaluate outliers consuming more time to process than just looking at the throughput numbers
---
.../apache/camel/itest/jmh/BlockingProducerToSedaTest.java | 8 ++++----
.../BlockingProducerWithArrayBlockingQueueToSedaTest.java | 8 ++++----
.../camel/itest/jmh/DisruptorMultipleTypesProducerTest.java | 12 ++++++------
.../org/apache/camel/itest/jmh/DisruptorProducerTest.java | 12 ++++++------
4 files changed, 20 insertions(+), 20 deletions(-)
diff --git a/tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/BlockingProducerToSedaTest.java b/tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/BlockingProducerToSedaTest.java
index e8df3c0..62fcfc8 100644
--- a/tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/BlockingProducerToSedaTest.java
+++ b/tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/BlockingProducerToSedaTest.java
@@ -82,14 +82,14 @@ public class BlockingProducerToSedaTest {
}
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
public void sendBlocking(BenchmarkState state, Blackhole bh) {
state.producerTemplate.sendBody(state.endpoint, "test");
}
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(6)
public void sendBlocking_6(BenchmarkState state, Blackhole bh) {
@@ -98,7 +98,7 @@ public class BlockingProducerToSedaTest {
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
public void sendBlockingWithMultipleTypes(BenchmarkState state, Blackhole bh) {
state.producerTemplate.sendBody(state.endpoint, "test");
@@ -108,7 +108,7 @@ public class BlockingProducerToSedaTest {
}
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(6)
public void sendBlockingWithMultipleTypes_6(BenchmarkState state, Blackhole bh) {
diff --git a/tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/BlockingProducerWithArrayBlockingQueueToSedaTest.java b/tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/BlockingProducerWithArrayBlockingQueueToSedaTest.java
index 57db655..08c7161 100644
--- a/tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/BlockingProducerWithArrayBlockingQueueToSedaTest.java
+++ b/tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/BlockingProducerWithArrayBlockingQueueToSedaTest.java
@@ -82,14 +82,14 @@ public class BlockingProducerWithArrayBlockingQueueToSedaTest {
}
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
public void sendBlocking(BenchmarkState state, Blackhole bh) {
state.producerTemplate.sendBody(state.endpoint, "test");
}
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(6)
public void sendBlocking_6(BenchmarkState state, Blackhole bh) {
@@ -98,7 +98,7 @@ public class BlockingProducerWithArrayBlockingQueueToSedaTest {
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
public void sendBlockingWithMultipleTypes(BenchmarkState state, Blackhole bh) {
state.producerTemplate.sendBody(state.endpoint, "test");
@@ -108,7 +108,7 @@ public class BlockingProducerWithArrayBlockingQueueToSedaTest {
}
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(6)
public void sendBlockingWithMultipleTypes_6(BenchmarkState state, Blackhole bh) {
diff --git a/tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/DisruptorMultipleTypesProducerTest.java b/tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/DisruptorMultipleTypesProducerTest.java
index 2a1fa03..4d82cd3 100644
--- a/tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/DisruptorMultipleTypesProducerTest.java
+++ b/tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/DisruptorMultipleTypesProducerTest.java
@@ -79,7 +79,7 @@ public class DisruptorMultipleTypesProducerTest {
}
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
public void sendMultipleTypes_1(BenchmarkState state, Blackhole bh) {
state.producerTemplate.sendBody(state.endpoint, "test");
@@ -89,7 +89,7 @@ public class DisruptorMultipleTypesProducerTest {
}
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(2)
public void sendBlockingWithMultipleTypes_2(BenchmarkState state, Blackhole bh) {
@@ -100,7 +100,7 @@ public class DisruptorMultipleTypesProducerTest {
}
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(4)
public void sendBlockingWithMultipleTypes_4(BenchmarkState state, Blackhole bh) {
@@ -111,7 +111,7 @@ public class DisruptorMultipleTypesProducerTest {
}
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(8)
public void sendBlockingWithMultipleTypes_8(BenchmarkState state, Blackhole bh) {
@@ -123,7 +123,7 @@ public class DisruptorMultipleTypesProducerTest {
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(16)
public void sendBlockingWithMultipleTypes_16(BenchmarkState state, Blackhole bh) {
@@ -134,7 +134,7 @@ public class DisruptorMultipleTypesProducerTest {
}
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(32)
public void sendBlockingWithMultipleTypes_32(BenchmarkState state, Blackhole bh) {
diff --git a/tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/DisruptorProducerTest.java b/tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/DisruptorProducerTest.java
index f93fa79..e13cbfb 100644
--- a/tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/DisruptorProducerTest.java
+++ b/tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/DisruptorProducerTest.java
@@ -75,14 +75,14 @@ public class DisruptorProducerTest {
}
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
public void send_1(BenchmarkState state, Blackhole bh) {
state.producerTemplate.sendBody(state.endpoint, "test");
}
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(2)
public void send_2(BenchmarkState state, Blackhole bh) {
@@ -91,7 +91,7 @@ public class DisruptorProducerTest {
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(4)
public void send_4(BenchmarkState state, Blackhole bh) {
@@ -99,7 +99,7 @@ public class DisruptorProducerTest {
}
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(8)
public void send_8(BenchmarkState state, Blackhole bh) {
@@ -107,7 +107,7 @@ public class DisruptorProducerTest {
}
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(16)
public void send_16(BenchmarkState state, Blackhole bh) {
@@ -115,7 +115,7 @@ public class DisruptorProducerTest {
}
@OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
+ @BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(32)
public void send_32(BenchmarkState state, Blackhole bh) {