Mutex pool that can be used to limit the number of workers operating at the same time

MutexPool.kt

import kotlinx.coroutines.selects.select
import kotlinx.coroutines.sync.Mutex

class MutexPool(val pool: Set<Mutex>) {
    constructor(poolSize: Int) : this((1..poolSize).map { Mutex() }.toSet())

    suspend inline fun <R> withLock(crossinline block: () -> R): R = select {
        pool.forEach {
            it.onLock { lockedMutex ->
                try {
                    block()
                } finally {
                    lockedMutex.unlock()
                }
            }
        }
    }
}