diff --git a/server/src/test/java/org/elasticsearch/common/util/concurrent/PrioritizedThrottledTaskRunnerTests.java b/server/src/test/java/org/elasticsearch/common/util/concurrent/PrioritizedThrottledTaskRunnerTests.java index 0fd29e4ee303e..58907436c9dad 100644 --- a/server/src/test/java/org/elasticsearch/common/util/concurrent/PrioritizedThrottledTaskRunnerTests.java +++ b/server/src/test/java/org/elasticsearch/common/util/concurrent/PrioritizedThrottledTaskRunnerTests.java @@ -231,9 +231,14 @@ private int getRandomPriority() { } private void assertNoRunningTasks(PrioritizedThrottledTaskRunner taskRunner) { + logger.info("--> ensure that there are no running tasks in the executor. Max number of threads [{}]", maxThreads); final var barrier = new CyclicBarrier(maxThreads + 1); for (int i = 0; i < maxThreads; i++) { - executor.execute(() -> awaitBarrier(barrier)); + executor.execute(() -> { + logger.info("--> await until barrier is released"); + awaitBarrier(barrier); + logger.info("--> the barrier is released"); + }); } awaitBarrier(barrier); assertThat(taskRunner.runningTasks(), equalTo(0));