andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Make JMH options modifiable through the subclassed benchmark.

Browse Source
This commit is contained in:
Michael Nitschinger 2014-01-14 13:34:23 +01:00 committed by Norman Maurer
parent 437a9403b0
commit 99f9c6dbc3
2 changed files with 28 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
microbench/src/test/java/io/netty/microbench/buffer/ByteBufAllocatorBenchmark.java
View File

@ -21,13 +21,10 @@ import io.netty.buffer.PooledByteBufAllocator;
import io.netty.buffer.UnpooledByteBufAllocator; import io.netty.buffer.UnpooledByteBufAllocator;
import io.netty.microbench.util.AbstractMicrobenchmark; import io.netty.microbench.util.AbstractMicrobenchmark;
import org.openjdk.jmh.annotations.GenerateMicroBenchmark; import org.openjdk.jmh.annotations.GenerateMicroBenchmark;
import org.openjdk.jmh.annotations.Scope;
import org.openjdk.jmh.annotations.State;
/** /**
* This class benchmarks different allocators with different allocation sizes. * This class benchmarks different allocators with different allocation sizes.
*/ */
@State(Scope.Thread)
public class ByteBufAllocatorBenchmark extends AbstractMicrobenchmark { public class ByteBufAllocatorBenchmark extends AbstractMicrobenchmark {
private final ByteBufAllocator unpooledHeapAllocator = new UnpooledByteBufAllocator(false); private final ByteBufAllocator unpooledHeapAllocator = new UnpooledByteBufAllocator(false);

40
microbench/src/test/java/io/netty/microbench/util/AbstractMicrobenchmark.java
View File

@ -17,11 +17,14 @@ package io.netty.microbench.util;
import io.netty.util.ResourceLeakDetector; import io.netty.util.ResourceLeakDetector;
import org.junit.Test; import org.junit.Test;
import org.openjdk.jmh.output.OutputFormatType; import org.openjdk.jmh.annotations.Fork;
import org.openjdk.jmh.annotations.Measurement;
import org.openjdk.jmh.annotations.Scope;
import org.openjdk.jmh.annotations.State;
import org.openjdk.jmh.annotations.Warmup;
import org.openjdk.jmh.output.results.ResultFormatType; import org.openjdk.jmh.output.results.ResultFormatType;
import org.openjdk.jmh.runner.Runner; import org.openjdk.jmh.runner.Runner;
import org.openjdk.jmh.runner.options.ChainedOptionsBuilder; import org.openjdk.jmh.runner.options.ChainedOptionsBuilder;
import org.openjdk.jmh.runner.options.Options;
import org.openjdk.jmh.runner.options.OptionsBuilder; import org.openjdk.jmh.runner.options.OptionsBuilder;
import java.io.File; import java.io.File;
@ -29,11 +32,15 @@ import java.io.File;
/** /**
* Base class for all JMH benchmarks. * Base class for all JMH benchmarks.
*/ */
@Warmup(iterations = AbstractMicrobenchmark.DEFAULT_WARMUP_ITERATIONS)
@Measurement(iterations = AbstractMicrobenchmark.DEFAULT_MEASURE_ITERATIONS)
@Fork(AbstractMicrobenchmark.DEFAULT_FORKS)
@State(Scope.Thread)
public class AbstractMicrobenchmark { public class AbstractMicrobenchmark {
protected static final String WARMUP_ITERATIONS = "10"; protected static final int DEFAULT_WARMUP_ITERATIONS = 10;
protected static final String MEASURE_ITERATIONS = "10"; protected static final int DEFAULT_MEASURE_ITERATIONS = 1;
protected static final String NUM_FORKS = "2"; protected static final int DEFAULT_FORKS = 2;
protected static final String JVM_ARGS = "-server -dsa -da -ea:io.netty... -Xms768m" + protected static final String JVM_ARGS = "-server -dsa -da -ea:io.netty... -Xms768m" +
" -Xmx768m -XX:MaxDirectMemorySize=768m -XX:+AggressiveOpts -XX:+UseBiasedLocking" + " -Xmx768m -XX:MaxDirectMemorySize=768m -XX:+AggressiveOpts -XX:+UseBiasedLocking" +
@ -50,10 +57,19 @@ public class AbstractMicrobenchmark {
ChainedOptionsBuilder runnerOptions = new OptionsBuilder() ChainedOptionsBuilder runnerOptions = new OptionsBuilder()
.include(".*" + className + ".*") .include(".*" + className + ".*")
.jvmArgs(JVM_ARGS) .jvmArgs(JVM_ARGS);
.warmupIterations(getWarmupIterations())
.measurementIterations(getMeasureIterations()) if (getWarmupIterations() > 0) {
.forks(getForks()); runnerOptions.warmupIterations(getWarmupIterations());
}
if (getMeasureIterations() > 0) {
runnerOptions.measurementIterations(getMeasureIterations());
}
if (getForks() > 0) {
runnerOptions.forks(getForks());
}
if (getReportDir() != null) { if (getReportDir() != null) {
String filePath = getReportDir() + className + ".json"; String filePath = getReportDir() + className + ".json";
@ -73,15 +89,15 @@ public class AbstractMicrobenchmark {
} }
protected int getWarmupIterations() { protected int getWarmupIterations() {
return Integer.parseInt(System.getProperty("warmupIterations", WARMUP_ITERATIONS)); return Integer.parseInt(System.getProperty("warmupIterations", "-1"));
} }
protected int getMeasureIterations() { protected int getMeasureIterations() {
return Integer.parseInt(System.getProperty("measureIterations", MEASURE_ITERATIONS)); return Integer.parseInt(System.getProperty("measureIterations", "-1"));
} }
protected int getForks() { protected int getForks() {
return Integer.parseInt(System.getProperty("forks", NUM_FORKS)); return Integer.parseInt(System.getProperty("forks", "-1"));
} }
protected String getReportDir() { protected String getReportDir() {