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:10 UTC
[camel-performance-tests] branch main updated (53f7a6b -> d182806)
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git
from 53f7a6b (chores) performance: increase the test timeout, since more tests are running
new 248d67c (chores) performance: break the disruptor tests for easier maintenance
new 118a95a (chores) performance: remove unused variables
new de53578 (chores) performance: use the average time for the seda and disruptor tests
new d182806 (chores) performance: break disruptor tests
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../itest/jmh/BlockingProducerToSedaTest.java | 8 +-
...ngProducerWithArrayBlockingQueueToSedaTest.java | 8 +-
...ava => DisruptorMultipleTypesProducerTest.java} | 52 +++++-----
.../camel/itest/jmh/DisruptorProducerTest.java | 114 ++-------------------
....java => DisruptorScalabilityProducerTest.java} | 60 ++++-------
5 files changed, 64 insertions(+), 178 deletions(-)
copy tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/{BlockingProducerToSedaTest.java => DisruptorMultipleTypesProducerTest.java} (70%)
copy tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/{BlockingProducerToSedaTest.java => DisruptorScalabilityProducerTest.java} (57%)
[camel-performance-tests] 04/04: (chores) performance: break disruptor tests
Posted by or...@apache.org.
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 d18280655cd742d876dc12bacf811a0e4b9a43d1
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Thu May 11 12:34:19 2023 +0200
(chores) performance: break disruptor tests
Separate some tests that are only useful when running on large machines
---
.../jmh/DisruptorMultipleTypesProducerTest.java | 48 +++++-----------------
.../camel/itest/jmh/DisruptorProducerTest.java | 37 ++++-------------
....java => DisruptorScalabilityProducerTest.java} | 40 +++++-------------
3 files changed, 28 insertions(+), 97 deletions(-)
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 4d82cd3..efee2cc 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
@@ -25,6 +25,12 @@ import org.openjdk.jmh.runner.Runner;
import org.openjdk.jmh.runner.options.Options;
import org.openjdk.jmh.runner.options.OptionsBuilder;
+
+/**
+ * This tests the disruptor component when running with a small threads and exchanging data with different types. This is
+ * suitable for most cases when a large machine with too many cores is not available (as it limits to a maximum of 4 consumers
+ * + 4 producers).
+ */
public class DisruptorMultipleTypesProducerTest {
@Test
@@ -48,7 +54,7 @@ public class DisruptorMultipleTypesProducerTest {
// http://hg.openjdk.java.net/code-tools/jmh/file/tip/jmh-samples/src/main/java/org/openjdk/jmh/samples/
@State(Scope.Benchmark)
public static class BenchmarkState {
- @Param({"1", "2", "4", "8", "16", "32"})
+ @Param({"1", "2", "4"})
int consumers;
CamelContext context;
@@ -78,7 +84,7 @@ public class DisruptorMultipleTypesProducerTest {
}
}
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
+ @OutputTimeUnit(TimeUnit.MICROSECONDS)
@BenchmarkMode(Mode.AverageTime)
@Benchmark
public void sendMultipleTypes_1(BenchmarkState state, Blackhole bh) {
@@ -88,7 +94,7 @@ public class DisruptorMultipleTypesProducerTest {
state.producerTemplate.sendBody(state.endpoint, state.sampleFile);
}
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
+ @OutputTimeUnit(TimeUnit.MICROSECONDS)
@BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(2)
@@ -99,7 +105,7 @@ public class DisruptorMultipleTypesProducerTest {
state.producerTemplate.sendBody(state.endpoint, state.sampleFile);
}
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
+ @OutputTimeUnit(TimeUnit.MICROSECONDS)
@BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(4)
@@ -109,38 +115,4 @@ public class DisruptorMultipleTypesProducerTest {
state.producerTemplate.sendBody(state.endpoint, state.someLong);
state.producerTemplate.sendBody(state.endpoint, state.sampleFile);
}
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode(Mode.AverageTime)
- @Benchmark
- @Threads(8)
- public void sendBlockingWithMultipleTypes_8(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- state.producerTemplate.sendBody(state.endpoint, state.someInt);
- state.producerTemplate.sendBody(state.endpoint, state.someLong);
- state.producerTemplate.sendBody(state.endpoint, state.sampleFile);
- }
-
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode(Mode.AverageTime)
- @Benchmark
- @Threads(16)
- public void sendBlockingWithMultipleTypes_16(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- state.producerTemplate.sendBody(state.endpoint, state.someInt);
- state.producerTemplate.sendBody(state.endpoint, state.someLong);
- state.producerTemplate.sendBody(state.endpoint, state.sampleFile);
- }
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode(Mode.AverageTime)
- @Benchmark
- @Threads(32)
- public void sendBlockingWithMultipleTypes_32(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- state.producerTemplate.sendBody(state.endpoint, state.someInt);
- state.producerTemplate.sendBody(state.endpoint, state.someLong);
- state.producerTemplate.sendBody(state.endpoint, state.sampleFile);
- }
}
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 e13cbfb..2bc22ad 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
@@ -1,6 +1,5 @@
package org.apache.camel.itest.jmh;
-import java.io.File;
import java.util.concurrent.TimeUnit;
import org.apache.camel.CamelContext;
@@ -25,6 +24,10 @@ import org.openjdk.jmh.runner.Runner;
import org.openjdk.jmh.runner.options.Options;
import org.openjdk.jmh.runner.options.OptionsBuilder;
+/**
+ * This tests the disruptor component when running with a small threads. This is suitable for most cases when
+ * a large machine with too many cores is not available (as it limits to a maximum of 4 consumers + 4 producers).
+ */
public class DisruptorProducerTest {
@Test
@@ -48,7 +51,7 @@ public class DisruptorProducerTest {
// http://hg.openjdk.java.net/code-tools/jmh/file/tip/jmh-samples/src/main/java/org/openjdk/jmh/samples/
@State(Scope.Benchmark)
public static class BenchmarkState {
- @Param({"1", "2", "4", "8", "16", "32"})
+ @Param({"1", "2", "4"})
int consumers;
CamelContext context;
@@ -74,14 +77,14 @@ public class DisruptorProducerTest {
}
}
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
+ @OutputTimeUnit(TimeUnit.MICROSECONDS)
@BenchmarkMode(Mode.AverageTime)
@Benchmark
public void send_1(BenchmarkState state, Blackhole bh) {
state.producerTemplate.sendBody(state.endpoint, "test");
}
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
+ @OutputTimeUnit(TimeUnit.MICROSECONDS)
@BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(2)
@@ -90,35 +93,11 @@ public class DisruptorProducerTest {
}
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
+ @OutputTimeUnit(TimeUnit.MICROSECONDS)
@BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(4)
public void send_4(BenchmarkState state, Blackhole bh) {
state.producerTemplate.sendBody(state.endpoint, "test");
}
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode(Mode.AverageTime)
- @Benchmark
- @Threads(8)
- public void send_8(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- }
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode(Mode.AverageTime)
- @Benchmark
- @Threads(16)
- public void send_16(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- }
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode(Mode.AverageTime)
- @Benchmark
- @Threads(32)
- public void send_32(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- }
}
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/DisruptorScalabilityProducerTest.java
similarity index 77%
copy from tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/DisruptorProducerTest.java
copy to tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/DisruptorScalabilityProducerTest.java
index e13cbfb..2840349 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/DisruptorScalabilityProducerTest.java
@@ -1,6 +1,5 @@
package org.apache.camel.itest.jmh;
-import java.io.File;
import java.util.concurrent.TimeUnit;
import org.apache.camel.CamelContext;
@@ -25,7 +24,12 @@ import org.openjdk.jmh.runner.Runner;
import org.openjdk.jmh.runner.options.Options;
import org.openjdk.jmh.runner.options.OptionsBuilder;
-public class DisruptorProducerTest {
+/**
+ * This tests the scalability of the disruptor component when running with many threads. You need a large machine for running
+ * this reliably: desktops and machines with a small number of cores may introduce excessive scheduler latency affecting the
+ * results.
+ */
+public class DisruptorScalabilityProducerTest {
@Test
public void launchBenchmark() throws Exception {
@@ -48,7 +52,7 @@ public class DisruptorProducerTest {
// http://hg.openjdk.java.net/code-tools/jmh/file/tip/jmh-samples/src/main/java/org/openjdk/jmh/samples/
@State(Scope.Benchmark)
public static class BenchmarkState {
- @Param({"1", "2", "4", "8", "16", "32"})
+ @Param({"1", "8", "16", "32"})
int consumers;
CamelContext context;
@@ -74,31 +78,7 @@ public class DisruptorProducerTest {
}
}
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode(Mode.AverageTime)
- @Benchmark
- public void send_1(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- }
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode(Mode.AverageTime)
- @Benchmark
- @Threads(2)
- public void send_2(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- }
-
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode(Mode.AverageTime)
- @Benchmark
- @Threads(4)
- public void send_4(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- }
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
+ @OutputTimeUnit(TimeUnit.MICROSECONDS)
@BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(8)
@@ -106,7 +86,7 @@ public class DisruptorProducerTest {
state.producerTemplate.sendBody(state.endpoint, "test");
}
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
+ @OutputTimeUnit(TimeUnit.MICROSECONDS)
@BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(16)
@@ -114,7 +94,7 @@ public class DisruptorProducerTest {
state.producerTemplate.sendBody(state.endpoint, "test");
}
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
+ @OutputTimeUnit(TimeUnit.MICROSECONDS)
@BenchmarkMode(Mode.AverageTime)
@Benchmark
@Threads(32)
[camel-performance-tests] 01/04: (chores) performance: break the disruptor tests for easier maintenance
Posted by or...@apache.org.
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 248d67c1961628b5d08e2386939d2af81bfe01ea
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Wed May 10 19:11:28 2023 +0200
(chores) performance: break the disruptor tests for easier maintenance
---
...ava => DisruptorMultipleTypesProducerTest.java} | 51 +---------------
.../camel/itest/jmh/DisruptorProducerTest.java | 67 ----------------------
2 files changed, 1 insertion(+), 117 deletions(-)
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/DisruptorMultipleTypesProducerTest.java
similarity index 77%
copy from tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/DisruptorProducerTest.java
copy to tests/camel-jmh/src/test/java/org/apache/camel/itest/jmh/DisruptorMultipleTypesProducerTest.java
index 6b6898b..2a1fa03 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/DisruptorMultipleTypesProducerTest.java
@@ -25,7 +25,7 @@ import org.openjdk.jmh.runner.Runner;
import org.openjdk.jmh.runner.options.Options;
import org.openjdk.jmh.runner.options.OptionsBuilder;
-public class DisruptorProducerTest {
+public class DisruptorMultipleTypesProducerTest {
@Test
public void launchBenchmark() throws Exception {
@@ -78,55 +78,6 @@ public class DisruptorProducerTest {
}
}
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
- @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})
- @Benchmark
- @Threads(2)
- public void send_2(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- }
-
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
- @Benchmark
- @Threads(4)
- public void send_4(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- }
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
- @Benchmark
- @Threads(8)
- public void send_8(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- }
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
- @Benchmark
- @Threads(16)
- public void send_16(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- }
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
- @Benchmark
- @Threads(32)
- public void send_32(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- }
-
-
@OutputTimeUnit(TimeUnit.MILLISECONDS)
@BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
@Benchmark
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 6b6898b..5b3a6a7 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
@@ -125,71 +125,4 @@ public class DisruptorProducerTest {
public void send_32(BenchmarkState state, Blackhole bh) {
state.producerTemplate.sendBody(state.endpoint, "test");
}
-
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
- @Benchmark
- public void sendMultipleTypes_1(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- state.producerTemplate.sendBody(state.endpoint, state.someInt);
- state.producerTemplate.sendBody(state.endpoint, state.someLong);
- state.producerTemplate.sendBody(state.endpoint, state.sampleFile);
- }
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
- @Benchmark
- @Threads(2)
- public void sendBlockingWithMultipleTypes_2(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- state.producerTemplate.sendBody(state.endpoint, state.someInt);
- state.producerTemplate.sendBody(state.endpoint, state.someLong);
- state.producerTemplate.sendBody(state.endpoint, state.sampleFile);
- }
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
- @Benchmark
- @Threads(4)
- public void sendBlockingWithMultipleTypes_4(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- state.producerTemplate.sendBody(state.endpoint, state.someInt);
- state.producerTemplate.sendBody(state.endpoint, state.someLong);
- state.producerTemplate.sendBody(state.endpoint, state.sampleFile);
- }
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
- @Benchmark
- @Threads(8)
- public void sendBlockingWithMultipleTypes_8(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- state.producerTemplate.sendBody(state.endpoint, state.someInt);
- state.producerTemplate.sendBody(state.endpoint, state.someLong);
- state.producerTemplate.sendBody(state.endpoint, state.sampleFile);
- }
-
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
- @Benchmark
- @Threads(16)
- public void sendBlockingWithMultipleTypes_16(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- state.producerTemplate.sendBody(state.endpoint, state.someInt);
- state.producerTemplate.sendBody(state.endpoint, state.someLong);
- state.producerTemplate.sendBody(state.endpoint, state.sampleFile);
- }
-
- @OutputTimeUnit(TimeUnit.MILLISECONDS)
- @BenchmarkMode({Mode.Throughput, Mode.AverageTime, Mode.SingleShotTime})
- @Benchmark
- @Threads(32)
- public void sendBlockingWithMultipleTypes_32(BenchmarkState state, Blackhole bh) {
- state.producerTemplate.sendBody(state.endpoint, "test");
- state.producerTemplate.sendBody(state.endpoint, state.someInt);
- state.producerTemplate.sendBody(state.endpoint, state.someLong);
- state.producerTemplate.sendBody(state.endpoint, state.sampleFile);
- }
}
[camel-performance-tests] 03/04: (chores) performance: use the average time for the seda and disruptor tests
Posted by or...@apache.org.
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) {
[camel-performance-tests] 02/04: (chores) performance: remove unused variables
Posted by or...@apache.org.
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 118a95ad539536f26df1332d0f88049ab8f7cd1c
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Wed May 10 19:14:49 2023 +0200
(chores) performance: remove unused variables
---
.../test/java/org/apache/camel/itest/jmh/DisruptorProducerTest.java | 4 ----
1 file changed, 4 deletions(-)
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 5b3a6a7..f93fa79 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
@@ -55,10 +55,6 @@ public class DisruptorProducerTest {
ProducerTemplate producerTemplate;
Endpoint endpoint;
- File sampleFile = new File("some-file");
- Integer someInt = Integer.valueOf(1);
- Long someLong = Long.valueOf(2);
-
@Setup(Level.Trial)
public void initialize() throws Exception {
context = new DefaultCamelContext();