diff --git a/src/main/java/teetime/framework/Analysis.java b/src/main/java/teetime/framework/Analysis.java index 34e7898deb90e1e10f9c37094e786da8999866aa..b71cfd5552aec86300e196ab2e3e31599a1e3329 100644 --- a/src/main/java/teetime/framework/Analysis.java +++ b/src/main/java/teetime/framework/Analysis.java @@ -163,6 +163,7 @@ public final class Analysis<T extends AnalysisConfiguration> implements Uncaught private Thread createThread(final AbstractExceptionListener newListener, final Set<Stage> intraStages, final Stage stage, final AbstractRunnableStage runnable) { final Thread thread = new Thread(runnable); stage.setExceptionHandler(newListener); + stage.setOwningThread(thread); for (Stage intraStage : intraStages) { intraStage.setOwningThread(thread); intraStage.setExceptionHandler(newListener);