From 4663372849f6fbad7f8bb20d85f17b02e538ea73 Mon Sep 17 00:00:00 2001 From: Christian Wulf <chw@informatik.uni-kiel.de> Date: Tue, 7 Jul 2015 11:47:52 +0200 Subject: [PATCH] added proposal for #200 --- src/main/java/teetime/framework/AbstractRunnableStage.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/main/java/teetime/framework/AbstractRunnableStage.java b/src/main/java/teetime/framework/AbstractRunnableStage.java index 7e4965e6..c5d3eb42 100644 --- a/src/main/java/teetime/framework/AbstractRunnableStage.java +++ b/src/main/java/teetime/framework/AbstractRunnableStage.java @@ -32,6 +32,8 @@ abstract class AbstractRunnableStage implements Runnable { public AbstractRunnableStage(final Stage stage) { this.stage = stage; this.logger = LoggerFactory.getLogger(stage.getClass()); + + // stage.owningContext.getThreadCounter().inc(); } @Override @@ -70,6 +72,8 @@ abstract class AbstractRunnableStage implements Runnable { throw new IllegalStateException("Terminated by StageExceptionListener"); } + // normal and exceptional termination + // stage.owningContext.getThreadCounter().dec(); } protected abstract void beforeStageExecution() throws InterruptedException; -- GitLab