Closable executor

Author: krystian-panek-vmltech

core/src/main/java/dev/vml/es/acm/core/script/ScriptScheduler.java

@@ -24,6 +24,7 @@
 import java.util.Map;
 import java.util.Optional;
 import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.sling.api.resource.LoginException;
@@ -137,12 +138,15 @@ public static JobType of(String value) {
 
  private Config config;
 
+ private ExecutorService deployJobExecutor;
+
  @Activate
  protected void activate(Config config) {
  this.config = config;
 
  if (checkInstanceReady()) {
- Executors.newSingleThreadExecutor().execute(this::deployJob);
+ deployJobExecutor = Executors.newSingleThreadExecutor();
+ deployJobExecutor.execute(this::deployJob);
  }
  }
 
@@ -153,6 +157,10 @@ protected void modify(Config config) {
 
  @Deactivate
  protected void deactivate() {
+ if (deployJobExecutor != null) {
+ deployJobExecutor.shutdownNow();
+ deployJobExecutor = null;
+ }
  unscheduleBoot();
  unscheduleScripts();
  bootedScripts.clear();