diff --git a/src/main/java/teetime/framework/Execution.java b/src/main/java/teetime/framework/Execution.java
index 3ef421c581b2a27040222a8465725771b987459c..2b8c3e060d00fb676d0a16d4f77f990ed6ec2a93 100644
--- a/src/main/java/teetime/framework/Execution.java
+++ b/src/main/java/teetime/framework/Execution.java
@@ -29,7 +29,6 @@ import org.slf4j.LoggerFactory;
 import teetime.framework.exceptionHandling.AbstractExceptionListener;
 import teetime.framework.exceptionHandling.IExceptionListenerFactory;
 import teetime.framework.exceptionHandling.TerminatingExceptionListenerFactory;
-import teetime.framework.signal.InitializingSignal;
 import teetime.framework.signal.ValidatingSignal;
 import teetime.framework.validation.AnalysisNotValidException;
 import teetime.util.ThreadThrowableContainer;
@@ -174,25 +173,21 @@ public final class Execution<T extends Configuration> implements UncaughtExcepti
 		switch (terminationStrategy) {
 		case BY_SIGNAL: {
 			final RunnableConsumerStage runnable = new RunnableConsumerStage(stage);
-			thread = createThread(runnable, stage.getId());
+			thread = createThread(runnable);
 			this.consumerThreads.add(thread);
 			break;
 		}
 		case BY_SELF_DECISION: {
 			final RunnableProducerStage runnable = new RunnableProducerStage(stage);
 			producerRunnables.add(runnable);
-			thread = createThread(runnable, stage.getId());
+			thread = createThread(runnable);
 			this.finiteProducerThreads.add(thread);
-			InitializingSignal initializingSignal = new InitializingSignal();
-			stage.onSignal(initializingSignal, null);
 			break;
 		}
 		case BY_INTERRUPT: {
 			final RunnableProducerStage runnable = new RunnableProducerStage(stage);
 			producerRunnables.add(runnable);
-			thread = createThread(runnable, stage.getId());
-			InitializingSignal initializingSignal = new InitializingSignal();
-			stage.onSignal(initializingSignal, null);
+			thread = createThread(runnable);
 			this.infiniteProducerThreads.add(thread);
 			break;
 		}
@@ -202,7 +197,7 @@ public final class Execution<T extends Configuration> implements UncaughtExcepti
 		return thread;
 	}
 
-	private Thread createThread(final AbstractRunnableStage runnable, final String name) {
+	private Thread createThread(final AbstractRunnableStage runnable) {
 		final Thread thread = new Thread(runnable);
 		thread.setUncaughtExceptionHandler(this);
 		thread.setName(configuration.getContext().getThreadableStages().get(runnable.stage));