Skip to content
Snippets Groups Projects
Commit 69758416 authored by Nelson Tavares de Sousa's avatar Nelson Tavares de Sousa
Browse files

merged master into this branch and removed error logging in analysis

parent aa52e5d1
No related branches found
No related tags found
No related merge requests found
...@@ -30,8 +30,6 @@ public class Analysis implements UncaughtExceptionHandler { ...@@ -30,8 +30,6 @@ public class Analysis implements UncaughtExceptionHandler {
private final Collection<Pair<Thread, Throwable>> exceptions = new ConcurrentLinkedQueue<Pair<Thread, Throwable>>(); private final Collection<Pair<Thread, Throwable>> exceptions = new ConcurrentLinkedQueue<Pair<Thread, Throwable>>();
private boolean initExecuted = false;
public Analysis(final AnalysisConfiguration configuration) { public Analysis(final AnalysisConfiguration configuration) {
this.configuration = configuration; this.configuration = configuration;
} }
...@@ -40,7 +38,6 @@ public class Analysis implements UncaughtExceptionHandler { ...@@ -40,7 +38,6 @@ public class Analysis implements UncaughtExceptionHandler {
* This initializes Analysis and needs to be run right before starting it. * This initializes Analysis and needs to be run right before starting it.
*/ */
public void init() { public void init() {
initExecuted = true;
final List<Stage> threadableStageJobs = this.configuration.getThreadableStageJobs(); final List<Stage> threadableStageJobs = this.configuration.getThreadableStageJobs();
for (Stage stage : threadableStageJobs) { for (Stage stage : threadableStageJobs) {
final Thread thread = new Thread(new RunnableStage(stage)); final Thread thread = new Thread(new RunnableStage(stage));
...@@ -67,9 +64,6 @@ public class Analysis implements UncaughtExceptionHandler { ...@@ -67,9 +64,6 @@ public class Analysis implements UncaughtExceptionHandler {
* @return a collection of thread/throwable pairs * @return a collection of thread/throwable pairs
*/ */
public Collection<Pair<Thread, Throwable>> start() { public Collection<Pair<Thread, Throwable>> start() {
if (!initExecuted) {
LOGGER.error("init() not executed before starting the analysis");
}
// start analysis // start analysis
startThreads(this.consumerThreads); startThreads(this.consumerThreads);
startThreads(this.finiteProducerThreads); startThreads(this.finiteProducerThreads);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment