iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update

Browse Source
This commit is contained in:
Brage 2023-07-30 21:29:15 +02:00
parent 930c76c7df
commit 039542d27c
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
Encode/src/main/kotlin/no/iktdev/streamit/content/encode/runner/RunnerCoordinator.kt
View File

@ -56,7 +56,8 @@ class RunnerCoordinator(private var maxConcurrentJobs: Int = 1) {
val job = processWorkItem(workItem) val job = processWorkItem(workItem)
inProgressJobs.add(job) inProgressJobs.add(job)
job.invokeOnCompletion { job.invokeOnCompletion {
logger.info { "Available workers: ${jobsInProgress.decrementAndGet()}/${maxConcurrentJobs}" } val workers = jobsInProgress.decrementAndGet()
logger.info { "Available workers: ${workers}/${maxConcurrentJobs}" }
inProgressJobs.remove(job) inProgressJobs.remove(job)
} }
} }