You need to add the following dependency:
<dependency>
<groupId>com.jupiter-tools</groupId>
<artifactId>stress-test</artifactId>
<version>0.1</version>
<scope>test</scope>
</dependency>
Let’s consider a simple web application :
Here we can create tasks and sub-tasks with titles, estimates, and weights(position in the list). When we create a sub-task we need to evaluate weight and set the next value for creating the task, because exists a unique constraint on the SubTask table in the database.
If we don’t synchronize API then multiple concurrent requests might let us to ConstraintViolationException.
In this case, StressTestRunner provide you an ability to check synchronization of your API:
@Test
void concurrentThreadsSubTasks() {
StressTestRunner.test()
.mode(ExecutionMode.TASK_EXECUTOR_MODE) (1)
.timeout(5, TimeUnit.SECONDS) (2)
.threads(4) (3)
.iterations(100) (4)
.run(this::createSubTaskSingleTest); (5)
}
private void createSubTaskSingleTest() throws Exception {
SubTask subTask = MvcRequester.on(mockMvc)
.to("tasks/{id}/subtasks/create", TASK_ID)
.withParam("title", "Make it safe!")
.withParam("estimate", 30)
.post()
.expectStatus(HttpStatus.CREATED)
.returnAs(SubTask.class);
assertThat(subTask).isNotNull()
.extracting(SubTask::getTitle, SubTask::getEstimate)
.contains("Make it safe!", 30);
}
-
test runner strategy (ThreadPoolExecutor based or Parallel Stream based)
-
time limit for tests passing
-
set threads count
-
set count of runs.
-
code of the one test iteration
When you need to compare a performance of multiple methods, you can use TestBenchmark extension:
@EnableTestBenchmark (1)
class EnableTestBenchmarkTest {
@Fast (2)
@TestBenchmark(measurementIterations = 15, warmupIterations = 10) (3)
void testFast() throws InterruptedException {
Thread.sleep(30);
}
@TestBenchmark(measurementIterations = 15, warmupIterations = 10)
void testSlow() throws InterruptedException {
Thread.sleep(100);
}
}
-
enable test extension
-
mark as Fast method which you expect will be faster
-
set measurement and warm-up iterations
If you measuring very fast methods (less than one milliseconds)
you can use MeasureUnit
annotation to set a unit of measurement profiling:
@EnableTestBenchmark
@MeasureUnit(unit = TimeUnit.NANOSECONDS)
class BenchmarkExtensionMeasureUnitTest {
@Fast
@TestBenchmark(measurementIterations = 15, warmupIterations = 10)
void testFast() {
}
@TestBenchmark(measurementIterations = 15, warmupIterations = 10)
void testSlow() throws InterruptedException {
Thread.sleep(1);
}
}