From 1502a623d7638d5513e268ebbf62e0404d9e42a4 Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Tue, 28 Jul 2015 11:15:56 +0200
Subject: [PATCH] removed sending InitializingSignal twice
---
src/main/java/teetime/framework/Execution.java | 13 ++++---------
1 file changed, 4 insertions(+), 9 deletions(-)
diff --git a/src/main/java/teetime/framework/Execution.java b/src/main/java/teetime/framework/Execution.java
index 3ef421c5..2b8c3e06 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));
--
GitLab