From bd129c442ee4fa91a35f743273c9f934f2070f6b Mon Sep 17 00:00:00 2001 From: Jonathan Shook Date: Tue, 20 Dec 2022 20:00:34 -0600 Subject: [PATCH] run activities within a dedicated executor --- .../lifecycle/{ => scenario}/ScenarioController.java | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) rename engine-core/src/main/java/io/nosqlbench/engine/core/lifecycle/{ => scenario}/ScenarioController.java (97%) diff --git a/engine-core/src/main/java/io/nosqlbench/engine/core/lifecycle/ScenarioController.java b/engine-core/src/main/java/io/nosqlbench/engine/core/lifecycle/scenario/ScenarioController.java similarity index 97% rename from engine-core/src/main/java/io/nosqlbench/engine/core/lifecycle/ScenarioController.java rename to engine-core/src/main/java/io/nosqlbench/engine/core/lifecycle/scenario/ScenarioController.java index 99929eeb4..8869e50cd 100644 --- a/engine-core/src/main/java/io/nosqlbench/engine/core/lifecycle/ScenarioController.java +++ b/engine-core/src/main/java/io/nosqlbench/engine/core/lifecycle/scenario/ScenarioController.java @@ -51,9 +51,16 @@ public class ScenarioController { private final String sessionId; private final Maturity minMaturity; - public ScenarioController(String sessionId, Maturity minMaturity) { - this.sessionId = sessionId; + private ExecutorService activitiesExecutor; + + public ScenarioController(Scenario scenario, Maturity minMaturity) { + this.scenario = scenario; this.minMaturity = minMaturity; + this.activityLoader = new ActivityLoader(scenario); + + ActivitiesExceptionHandler exceptionHandler = new ActivitiesExceptionHandler(this); + IndexedThreadFactory indexedThreadFactory = new IndexedThreadFactory("ACTIVITY", exceptionHandler); + this.activitiesExecutor = Executors.newCachedThreadPool(indexedThreadFactory); } /**