diff --git a/Encode/src/main/kotlin/no/iktdev/streamit/content/encode/runner/RunnerCoordinator.kt b/Encode/src/main/kotlin/no/iktdev/streamit/content/encode/runner/RunnerCoordinator.kt index 674c85ed..2b478046 100644 --- a/Encode/src/main/kotlin/no/iktdev/streamit/content/encode/runner/RunnerCoordinator.kt +++ b/Encode/src/main/kotlin/no/iktdev/streamit/content/encode/runner/RunnerCoordinator.kt @@ -56,7 +56,8 @@ class RunnerCoordinator(private var maxConcurrentJobs: Int = 1) { val job = processWorkItem(workItem) inProgressJobs.add(job) job.invokeOnCompletion { - logger.info { "Available workers: ${jobsInProgress.decrementAndGet()}/${maxConcurrentJobs}" } + val workers = jobsInProgress.decrementAndGet() + logger.info { "Available workers: ${workers}/${maxConcurrentJobs}" } inProgressJobs.remove(job) } }