Class BenchmarkHandler

java.lang.Object

org.openjdk.jmh.runner.BenchmarkHandler

class BenchmarkHandler
extends Object

Base class for all benchmarks handlers.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	BenchmarkHandler.BenchmarkTask	Worker body.
private static enum	BenchmarkHandler.ExecutorType
private static class	BenchmarkHandler.WorkerData	Handles thread-local data for each worker that should not change between the iterations.

Field Summary

Fields

Modifier and Type	Field	Description
private final Class<?>	clazz
private final ExecutorService	executor	Thread-pool for threads executing the benchmark tasks
private static final BenchmarkHandler.ExecutorType	EXECUTOR_TYPE
private final Method	method
private final OutputFormat	out
private final List<InternalProfiler>	profilers
private final List<InternalProfiler>	profilersRev
private final BlockingQueue<ThreadParams>	tps
private final ConcurrentMap<Thread, BenchmarkHandler.WorkerData>	workerData

Constructor Summary

Constructors

Constructor	Description
BenchmarkHandler(OutputFormat out, Options options, BenchmarkParams executionParams)

Method Summary

Modifier and Type	Method	Description
(package private) static List<ThreadParams>	distributeThreads(int threads, int[] groups)
static Method	findBenchmarkMethod(Class<?> clazz, String methodName)
private static boolean	isValidBenchmarkSignature(Method m)	checks if method signature is valid benchmark signature, besited checks if method signature corresponds to benchmark type.
private BenchmarkHandler.WorkerData	newWorkerData(Thread worker)
IterationResult	runIteration(BenchmarkParams benchmarkParams, IterationParams params, boolean last)	Runs an iteration on the handled benchmark.
void	shutdown()	Do required shutdown actions.
protected void	startProfilers(BenchmarkParams benchmarkParams, IterationParams iterationParams)
protected void	stopProfilers(BenchmarkParams benchmarkParams, IterationParams iterationParams, IterationResult iterationResults)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

executor

private final ExecutorService executor

Thread-pool for threads executing the benchmark tasks

workerData

private final ConcurrentMap<Thread, BenchmarkHandler.WorkerData> workerData

tps

private final BlockingQueue<ThreadParams> tps

out

private final OutputFormat out

profilers

private final List<InternalProfiler> profilers

profilersRev

private final List<InternalProfiler> profilersRev

clazz

private final Class<?> clazz

method

private final Method method

EXECUTOR_TYPE

private static final BenchmarkHandler.ExecutorType EXECUTOR_TYPE

Constructor Details

BenchmarkHandler

public BenchmarkHandler(OutputFormat out,
 Options options,
 BenchmarkParams executionParams)

Method Details

distributeThreads

static List<ThreadParams> distributeThreads(int threads,
 int[] groups)

findBenchmarkMethod

public static Method findBenchmarkMethod(Class<?> clazz,
 String methodName)

isValidBenchmarkSignature

private static boolean isValidBenchmarkSignature(Method m)

checks if method signature is valid benchmark signature, besited checks if method signature corresponds to benchmark type.

Parameters:

m -

Returns:

startProfilers

protected void startProfilers(BenchmarkParams benchmarkParams,
 IterationParams iterationParams)

stopProfilers

protected void stopProfilers(BenchmarkParams benchmarkParams,
 IterationParams iterationParams,
 IterationResult iterationResults)

shutdown

public void shutdown()

Do required shutdown actions.

runIteration

public IterationResult runIteration(BenchmarkParams benchmarkParams,
 IterationParams params,
 boolean last)

Runs an iteration on the handled benchmark.

Parameters:

benchmarkParams - Benchmark parameters

params - Iteration parameters

last - Should this iteration considered to be the last

Returns:

IterationResult

newWorkerData

private BenchmarkHandler.WorkerData newWorkerData(Thread worker)