moved wrapper watcher into an thread

BLUEAMETHYST-Studios · May 18, 2024 · 516ecf3 · 516ecf3
1 parent 9ef3dbf
commit 516ecf3
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 6 deletions.
diff --git a/wrapper/src/main/kotlin/me/blueamethyst/bluecloud/wrapper/Wrapper.kt b/wrapper/src/main/kotlin/me/blueamethyst/bluecloud/wrapper/Wrapper.kt
@@ -46,7 +46,10 @@ class Wrapper: AbstractSystemPart(InternalSystemPartType.WRAPPER) {
 
     private fun postStart() {
         logger.info("Starting Wrapper...")
-        WrapperWatcher.instance.start()
+        WrapperWatcher.instance.initialize()
+        while (true) {
+            Thread.sleep(50000)
+        }
     }
 
     private fun setupFileStructure() {

diff --git a/wrapper/src/main/kotlin/me/blueamethyst/bluecloud/wrapper/logic/WrapperWatcher.kt b/wrapper/src/main/kotlin/me/blueamethyst/bluecloud/wrapper/logic/WrapperWatcher.kt
@@ -3,27 +3,37 @@ package me.blueamethyst.bluecloud.wrapper.logic
 import me.blueamethyst.bluecloud.wrapper.Wrapper.Companion.logger
 import java.io.Closeable
 
-class WrapperWatcher: Closeable {
+class WrapperWatcher: Thread("wrapper-watcher"), Closeable {
     var running = false; private set
 
-    fun start() {
+    init {
+        isDaemon = true
+    }
+
+    fun initialize() {
         logger.info("Starting WrapperWatcher")
         running = true
-        spin()
+        start()
     }
 
     private fun spin() {
         while (running) {
-
+            //TODO: check if service is in the queue
+            sleep(1000)
         }
     }
 
     override fun close() {
-        logger.info("Closed WrapperWatcher")
         running = false
+        interrupt()
+        logger.info("Closed WrapperWatcher")
     }
 
     companion object {
         val instance = WrapperWatcher()
     }
+
+    override fun run() {
+        spin()
+    }
 }