From 92f6caf41160e857cc8306041f64a3975ccb3f86 Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Fri, 27 Mar 2015 14:12:17 +0100
Subject: [PATCH] minor refactoring
---
src/main/java/teetime/framework/Analysis.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/src/main/java/teetime/framework/Analysis.java b/src/main/java/teetime/framework/Analysis.java
index 0a701290..88bdbcfe 100644
--- a/src/main/java/teetime/framework/Analysis.java
+++ b/src/main/java/teetime/framework/Analysis.java
@@ -129,14 +129,15 @@ public final class Analysis implements UncaughtExceptionHandler {
newListener = factory.create();
switch (stage.getTerminationStrategy()) {
case BY_SIGNAL: {
- final Thread thread = new Thread(new RunnableConsumerStage(stage, newListener));
+ final RunnableConsumerStage runnableConsumerStage = new RunnableConsumerStage(stage, newListener);
+ final Thread thread = new Thread(runnableConsumerStage);
stage.setOwningThread(thread);
this.consumerThreads.add(thread);
thread.setName(stage.getId());
break;
}
case BY_SELF_DECISION: {
- RunnableProducerStage runnable = new RunnableProducerStage(stage, newListener);
+ final RunnableProducerStage runnable = new RunnableProducerStage(stage, newListener);
final Thread thread = new Thread(runnable);
stage.setOwningThread(thread);
this.finiteProducerThreads.add(thread);
@@ -144,7 +145,7 @@ public final class Analysis implements UncaughtExceptionHandler {
break;
}
case BY_INTERRUPT: {
- RunnableProducerStage runnable = new RunnableProducerStage(stage, newListener);
+ final RunnableProducerStage runnable = new RunnableProducerStage(stage, newListener);
final Thread thread = new Thread(runnable);
stage.setOwningThread(thread);
this.infiniteProducerThreads.add(thread);
--
GitLab