Skip to content

Commit db4a88c

Browse files
committed
Conditionally use a thread pool backed sequential executor for DSL rules and events
Signed-off-by: Jörg Sautter <[email protected]>
1 parent 32237a9 commit db4a88c

File tree

6 files changed

+705
-6
lines changed

6 files changed

+705
-6
lines changed

bundles/org.openhab.core.automation/src/main/java/org/openhab/core/automation/internal/TriggerHandlerCallbackImpl.java

+2-3
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,6 @@
1313
package org.openhab.core.automation.internal;
1414

1515
import java.util.Map;
16-
import java.util.concurrent.Executors;
1716
import java.util.concurrent.Future;
1817
import java.util.concurrent.ScheduledExecutorService;
1918

@@ -23,7 +22,7 @@
2322
import org.openhab.core.automation.RuleStatusInfo;
2423
import org.openhab.core.automation.Trigger;
2524
import org.openhab.core.automation.handler.TriggerHandlerCallback;
26-
import org.openhab.core.common.NamedThreadFactory;
25+
import org.openhab.core.common.ThreadPoolManager;
2726

2827
/**
2928
* 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 {
4847
protected TriggerHandlerCallbackImpl(RuleEngineImpl re, String ruleUID) {
4948
this.re = re;
5049
this.ruleUID = ruleUID;
51-
executor = Executors.newSingleThreadScheduledExecutor(new NamedThreadFactory("rule-" + ruleUID));
50+
this.executor = ThreadPoolManager.newSequentialScheduledExecutorService("rules-pool", "rule-" + ruleUID);
5251
}
5352

5453
@Override

0 commit comments

Comments
 (0)