From 0dbd0cb46cb6c00d5f12f75fc6885a30bc86db93 Mon Sep 17 00:00:00 2001
From: Nelson Tavares de Sousa <ntd@informatik.uni-kiel.de>
Date: Thu, 16 Apr 2015 17:07:03 +0200
Subject: [PATCH] moved one method to init
---
src/main/java/teetime/framework/Analysis.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/src/main/java/teetime/framework/Analysis.java b/src/main/java/teetime/framework/Analysis.java
index 9579e00d..aa6cd428 100644
--- a/src/main/java/teetime/framework/Analysis.java
+++ b/src/main/java/teetime/framework/Analysis.java
@@ -144,6 +144,7 @@ public final class Analysis<T extends AnalysisConfiguration> implements Uncaught
intraStage.setExceptionHandler(newListener);
}
this.consumerThreads.add(thread);
+ thread.setUncaughtExceptionHandler(this);
thread.setName(stage.getId());
break;
}
@@ -156,6 +157,7 @@ public final class Analysis<T extends AnalysisConfiguration> implements Uncaught
intraStage.setExceptionHandler(newListener);
}
this.finiteProducerThreads.add(thread);
+ thread.setUncaughtExceptionHandler(this);
thread.setName(stage.getId());
break;
}
@@ -168,6 +170,7 @@ public final class Analysis<T extends AnalysisConfiguration> implements Uncaught
intraStage.setExceptionHandler(newListener);
}
this.infiniteProducerThreads.add(thread);
+ thread.setUncaughtExceptionHandler(this);
thread.setName(stage.getId());
break;
}
@@ -298,7 +301,6 @@ public final class Analysis<T extends AnalysisConfiguration> implements Uncaught
private void startThreads(final Iterable<Thread> threads) {
for (Thread thread : threads) {
- thread.setUncaughtExceptionHandler(this);
thread.start();
}
}
--
GitLab