diff --git a/src/main/java/teetime/framework/Analysis.java b/src/main/java/teetime/framework/Analysis.java index 5319ef584a478c6514e807c6723b45a7e64d7aa5..32cf310a3665366b9ef2497834290659f854093d 100644 --- a/src/main/java/teetime/framework/Analysis.java +++ b/src/main/java/teetime/framework/Analysis.java @@ -30,8 +30,6 @@ public class Analysis implements UncaughtExceptionHandler { private final Collection<Pair<Thread, Throwable>> exceptions = new ConcurrentLinkedQueue<Pair<Thread, Throwable>>(); - private boolean initExecuted = false; - public Analysis(final AnalysisConfiguration configuration) { this.configuration = configuration; } @@ -40,7 +38,6 @@ public class Analysis implements UncaughtExceptionHandler { * This initializes Analysis and needs to be run right before starting it. */ public void init() { - initExecuted = true; final List<Stage> threadableStageJobs = this.configuration.getThreadableStageJobs(); for (Stage stage : threadableStageJobs) { final Thread thread = new Thread(new RunnableStage(stage)); @@ -67,9 +64,6 @@ public class Analysis implements UncaughtExceptionHandler { * @return a collection of thread/throwable pairs */ public Collection<Pair<Thread, Throwable>> start() { - if (!initExecuted) { - LOGGER.error("init() not executed before starting the analysis"); - } // start analysis startThreads(this.consumerThreads); startThreads(this.finiteProducerThreads);