From e3ecc30497142cfb66c1991e6f5814e38765f55e Mon Sep 17 00:00:00 2001 From: "Tristan B. Kildaire" Date: Thu, 19 May 2022 21:06:57 +0200 Subject: [PATCH] Running status should be set from within startTasky() and after starting all sub-systems --- source/tasky/engine.d | 31 +++++++++++++------------------ 1 file changed, 13 insertions(+), 18 deletions(-) diff --git a/source/tasky/engine.d b/source/tasky/engine.d index 830dcca..b7dbb02 100644 --- a/source/tasky/engine.d +++ b/source/tasky/engine.d @@ -34,34 +34,26 @@ public final class Engine : Thread /* Set the worker function */ super(&worker); - /* TODO: Check for exceptions */ /* Create a new event engine */ evEngine = new EvEngine(); - evEngine.start(); - - /* TODO: Check for exceptions */ + /* Create a new tristanable manager */ - tmanager = new Manager(socket, dur!("msecs")(100), true); - - /* Start the loop */ - running = true; - start(); + tmanager = new Manager(socket, dur!("msecs")(100), true); } /** - * Starts the Tasky engine - * - * FIXME: Pivot to using this - * FIXME: This code should be private and rather called at the beginning - * of `.start()` + * Start the sub-systems */ - public void startTasky() + private void startTasky() { /* Start the event engine */ - //evEngine.start(); + evEngine.start(); - /* TODO: TManager should not start immediately either I guess */ - //tmanager.start(); + /* Start the tristanable queue filter */ + tmanager.start(); + + /* Start the loop */ + running = true; } public class TaskyEvent : Event @@ -82,6 +74,9 @@ public final class Engine : Thread */ private void worker() { + /* Start all sub-systems */ + startTasky(); + while(running) { /**