reapply threading patch

VEuPathDB · Apr 19, 2024 · 4e31c35 · 4e31c35
1 parent 01c9c50
commit 4e31c35
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/components/async/src/main/kotlin/vdi/component/async/WorkerPool.kt b/components/async/src/main/kotlin/vdi/component/async/WorkerPool.kt
@@ -24,8 +24,7 @@ class WorkerPool(
   fun start() {
     log.info("starting worker pool $name with queue size $jobQueueSize and worker count $workerCount")
 
-//    runBlocking(Dispatchers.IO) {
-    runBlocking {
+    runBlocking(Dispatchers.IO) {
       repeat(workerCount) { i ->
         val j = i + 1
         launch (CoroutineThreadContext(contextData = ThreadContextData(map = mapOf("workerID" to "$name-$j"), Stack()))) {