diff --git a/src/main/java/teetime/framework/Execution.java b/src/main/java/teetime/framework/Execution.java index 67ed43a09737e23882b850463a301ba4cc2ad4a1..557f094d7c405c69f64160d836ea604562e68e6e 100644 --- a/src/main/java/teetime/framework/Execution.java +++ b/src/main/java/teetime/framework/Execution.java @@ -204,6 +204,8 @@ public final class Execution<T extends Configuration> implements UncaughtExcepti */ public void waitForTermination() { try { + // stage.owningContext.getThreadCounter().await(0); + LOGGER.debug("Waiting for finiteProducerThreads"); for (Thread thread : this.finiteProducerThreads) { thread.join();