IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

run activities within a dedicated executor

Browse Source
This commit is contained in:
Jonathan Shook 2022-12-20 20:00:34 -06:00
parent 2b39f3c350
commit bd129c442e
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
engine-core/src/main/java/io/nosqlbench/engine/core/lifecycle/ScenarioController.java → engine-core/src/main/java/io/nosqlbench/engine/core/lifecycle/scenario/ScenarioController.java
View File

@ -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);
}
/**