Thread.yield

cpuWorkerIdle

fun main() {
    runBlocking {
        val count = AtomicInteger()
        val ints = produce<Int> {
            repeat(10) {
                launch(Dispatchers.Default) {
                    while (true) {
                        channel.send(count.incrementAndGet())
                    }
                }
            }
        }
        for (int in ints) {
            // Single consumer doing something expensive that can't be concurrent
            Thread.sleep(2)
        }
    }
}