Conditionally use a thread pool backed sequential executor for DSL ru…

…les and events Signed-off-by: Jörg Sautter <[email protected]>
openhab · Dec 7, 2023 · 5cf06fe · 5cf06fe
1 parent 32237a9
commit 5cf06fe
Show file tree

Hide file tree

Showing 6 changed files with 681 additions and 6 deletions.
diff --git a/...mation/src/main/java/org/openhab/core/automation/internal/TriggerHandlerCallbackImpl.java b/...mation/src/main/java/org/openhab/core/automation/internal/TriggerHandlerCallbackImpl.java
@@ -13,7 +13,6 @@
 package org.openhab.core.automation.internal;
 
 import java.util.Map;
-import java.util.concurrent.Executors;
 import java.util.concurrent.Future;
 import java.util.concurrent.ScheduledExecutorService;
 
@@ -23,7 +22,7 @@
 import org.openhab.core.automation.RuleStatusInfo;
 import org.openhab.core.automation.Trigger;
 import org.openhab.core.automation.handler.TriggerHandlerCallback;
-import org.openhab.core.common.NamedThreadFactory;
+import org.openhab.core.common.ThreadPoolManager;
 
 /**
  * This class is implementation of {@link TriggerHandlerCallback} used by the {@link Trigger}s to notify rule engine
@@ -48,7 +47,7 @@ public class TriggerHandlerCallbackImpl implements TriggerHandlerCallback {
     protected TriggerHandlerCallbackImpl(RuleEngineImpl re, String ruleUID) {
         this.re = re;
         this.ruleUID = ruleUID;
-        executor = Executors.newSingleThreadScheduledExecutor(new NamedThreadFactory("rule-" + ruleUID));
+        this.executor = ThreadPoolManager.newSequentialScheduledExecutorService("rules-pool", "rule-" + ruleUID);
     }
 
     @Override