From 4e31c35455b0521d092dc05204c3dd0a2026598c Mon Sep 17 00:00:00 2001 From: Elizabeth Paige Harper Date: Fri, 19 Apr 2024 13:05:44 -0400 Subject: [PATCH] reapply threading patch --- .../async/src/main/kotlin/vdi/component/async/WorkerPool.kt | 3 +-- 1 file changed, 1 insertion(+), 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 index 0b6b315c..d4481a56 100644 --- 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()))) {