change: delay scheduler thread start

RelativityMC · Jul 26, 2024 · 59d7a0c · 59d7a0c
1 parent 7f35a22
commit 59d7a0c
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 1 deletion.
diff --git a/src/main/java/com/ishland/flowsched/scheduler/DaemonizedStatusAdvancingScheduler.java b/src/main/java/com/ishland/flowsched/scheduler/DaemonizedStatusAdvancingScheduler.java
@@ -25,7 +25,6 @@ public abstract class DaemonizedStatusAdvancingScheduler<K, V, Ctx, UserData> ex
 
     public DaemonizedStatusAdvancingScheduler(ThreadFactory threadFactory) {
         this.thread = threadFactory.newThread(this::mainLoop);
-        this.thread.start();
     }
 
     protected Queue<Runnable> createTaskQueue() {

diff --git a/src/test/java/com/ishland/flowsched/scheduler/support/TestSchedulerImpl.java b/src/test/java/com/ishland/flowsched/scheduler/support/TestSchedulerImpl.java
@@ -26,6 +26,7 @@ public class TestSchedulerImpl extends DaemonizedStatusAdvancingScheduler<Long,
 
     public TestSchedulerImpl(ThreadFactory threadFactory) {
         super(threadFactory);
+        this.thread.start();
     }
 
     @Override