Skip to content
Snippets Groups Projects
Commit 46633728 authored by Christian Wulf's avatar Christian Wulf
Browse files

added proposal for #200

parent ac23e617
No related branches found
No related tags found
No related merge requests found
......@@ -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;
......
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