From 5392d3f18becfc94fb42de49ce8ed22e3d15aef9 Mon Sep 17 00:00:00 2001 From: Christian Wulf <chw@informatik.uni-kiel.de> Date: Tue, 28 Jul 2015 11:17:11 +0200 Subject: [PATCH] minor refactoring --- src/main/java/teetime/framework/Execution.java | 11 ----------- 1 file changed, 11 deletions(-) diff --git a/src/main/java/teetime/framework/Execution.java b/src/main/java/teetime/framework/Execution.java index 2b8c3e06..4d05779d 100644 --- a/src/main/java/teetime/framework/Execution.java +++ b/src/main/java/teetime/framework/Execution.java @@ -163,7 +163,6 @@ public final class Execution<T extends Configuration> implements UncaughtExcepti startThreads(this.infiniteProducerThreads); sendInitializingSignal(); - } private Thread initializeThreadableStages(final Stage stage) { @@ -222,16 +221,6 @@ public final class Execution<T extends Configuration> implements UncaughtExcepti public void waitForTermination() { try { getConfiguration().getContext().getRunnableCounter().waitFor(0); - - // LOGGER.debug("Waiting for finiteProducerThreads"); - // for (Thread thread : this.finiteProducerThreads) { - // thread.join(); - // } - // - // LOGGER.debug("Waiting for consumerThreads"); - // for (Thread thread : this.consumerThreads) { - // thread.join(); - // } } catch (InterruptedException e) { LOGGER.error("Execution has stopped unexpectedly", e); for (Thread thread : this.finiteProducerThreads) { -- GitLab