Package step.artefacts.handlers.loadtesting

Class Pacer

java.lang.Object

step.artefacts.handlers.loadtesting.Pacer

public class Pacer
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Pacer.Context

Constructor Summary

Constructors

Constructor	Description
Pacer()

Method Summary

Modifier and Type	Method	Description
protected static void	debug(String message)
protected static boolean	isDebugEnabled()
static void	scheduleAtConstantPacing(Consumer<Integer> r, long pacingMs, long maxDurationInSeconds, ExecutionContext executionContext)
static void	scheduleAtConstantPacing(Consumer<Integer> r, long pacingMs, Predicate<Pacer.Context> predicate, ExecutionContext executionContext)
static void	scheduleAtConstantRate(Consumer<Integer> r, long executionsPerSecond, long maxDurationInSeconds, ExecutionContext executionContext)

Methods inherited from class java.lang.Object

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

Constructor Details

Pacer

public Pacer()

Method Details

scheduleAtConstantRate

public static void scheduleAtConstantRate(Consumer<Integer> r,
 long executionsPerSecond,
 long maxDurationInSeconds,
 ExecutionContext executionContext)
                                   throws InterruptedException

Throws:

InterruptedException

scheduleAtConstantPacing

public static void scheduleAtConstantPacing(Consumer<Integer> r,
 long pacingMs,
 long maxDurationInSeconds,
 ExecutionContext executionContext)
                                     throws InterruptedException

Throws:

InterruptedException

scheduleAtConstantPacing

public static void scheduleAtConstantPacing(Consumer<Integer> r,
 long pacingMs,
 Predicate<Pacer.Context> predicate,
 ExecutionContext executionContext)
                                     throws InterruptedException

Throws:

InterruptedException

isDebugEnabled

protected static boolean isDebugEnabled()

debug

protected static void debug(String message)