Class Pacer
- java.lang.Object
-
- step.artefacts.handlers.loadtesting.Pacer
-
public class Pacer extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
Pacer.Context
-
Constructor Summary
Constructors Constructor Description Pacer()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description protected static void
debug(java.lang.String message)
protected static boolean
isDebugEnabled()
static void
scheduleAtConstantPacing(java.util.function.Consumer<java.lang.Integer> r, long pacingMs, long maxDurationInSeconds)
static void
scheduleAtConstantPacing(java.util.function.Consumer<java.lang.Integer> r, long pacingMs, java.util.function.Predicate<Pacer.Context> predicate)
static void
scheduleAtConstantRate(java.util.function.Consumer<java.lang.Integer> r, long executionsPerSecond, long maxDurationInSeconds)
-
-
-
Method Detail
-
scheduleAtConstantRate
public static void scheduleAtConstantRate(java.util.function.Consumer<java.lang.Integer> r, long executionsPerSecond, long maxDurationInSeconds) throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
-
scheduleAtConstantPacing
public static void scheduleAtConstantPacing(java.util.function.Consumer<java.lang.Integer> r, long pacingMs, long maxDurationInSeconds) throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
-
scheduleAtConstantPacing
public static void scheduleAtConstantPacing(java.util.function.Consumer<java.lang.Integer> r, long pacingMs, java.util.function.Predicate<Pacer.Context> predicate) throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
-
isDebugEnabled
protected static boolean isDebugEnabled()
-
debug
protected static void debug(java.lang.String message)
-
-