long running tasks now don't block the start of a new task

src/main/kotlin/de/fraunhofer/iem/dataprovider/git/GitService.kt

 package de.fraunhofer.iem.dataprovider.git
 
+import de.fraunhofer.iem.dataprovider.taskManager.TaskManager
 import org.springframework.stereotype.Service
-import kotlinx.coroutines.*
-import kotlinx.coroutines.channels.*
+
 @Service
 class GitService(private val taskManager: TaskManager) {
 

src/main/kotlin/de/fraunhofer/iem/dataprovider/git/TaskManager.kt → src/main/kotlin/de/fraunhofer/iem/dataprovider/taskManager/TaskManager.kt

-package de.fraunhofer.iem.dataprovider.git
+package de.fraunhofer.iem.dataprovider.taskManager
 
+import de.fraunhofer.iem.dataprovider.logger.getLogger
 import jakarta.annotation.PostConstruct
 import jakarta.annotation.PreDestroy
 import kotlinx.coroutines.*
@@ -7,6 +8,10 @@ import kotlinx.coroutines.channels.Channel
 import org.springframework.stereotype.Component
 import kotlin.coroutines.CoroutineContext
 
+enum class TaskType{
+    REPO_CHANGED
+}
+data class Task(val type: TaskType, val payload: Any)
 @Component
 class TaskManager : CoroutineScope {
 
@@ -16,21 +21,25 @@ class TaskManager : CoroutineScope {
 
     // TODO: this could be dangerous to give it unlimited memory
     private val tasks = Channel<String>(Channel.UNLIMITED)
+    private val numCores = Runtime.getRuntime().availableProcessors()
+    private val logger = getLogger(javaClass)
 
     @PostConstruct
     fun startWorkers() {
-        // TODO: spawn threads equal to number of cores
-        repeat(10) {
-            println("[${Thread.currentThread().name}] launching coroutine")
+        logger.info("Starting $numCores workers.")
+        repeat(numCores-1) {
+            logger.info("[${Thread.currentThread().name}] launching coroutine")
             launchWorker(it)
         }
     }
 
     private fun launchWorker(id: Int) = launch {
         for (task in tasks) {
-            println("[${Thread.currentThread().name}] Processor #$id received $task")
-            executeTask(task)
-            println("[${Thread.currentThread().name}] Processor #$id finished $task")
+            launch {
+                logger.debug("[${Thread.currentThread().name}] Processor #$id received $task")
+                executeTask(task)
+                logger.debug("[${Thread.currentThread().name}] Processor #$id finished $task")
+            }
         }
     }
 

src/main/resources/application.properties

 spring.config.import=optional:classpath:.env[.properties]
 OPENCODE_GITLAB_URL=https://gitlab.opencode.de/
 OPENCODE_GITLAB_TOKEN=${OPENCODE_TOKEN}
-spring.r2dbc.url=${R2DBC_URL}
+spring.r2dbc.url=${R2DBC_URL}
\ No newline at end of file
+logging.level.root=DEBUG
\ No newline at end of file