Assumed I have an infinite source of tasks, for example some `ReceiveChannel` which lazily produces ...

# coroutines

[trathschlag]

Assumed I have an infinite source of tasks, for example some ReceiveChannel which lazily produces work and I want to schedule these on CommonPool. I can't just take every task from the source, because there are infinite. What's a good way to assure that for example always 1000 tasks are currently in my thread pool?

[elizarov]

Smth like this:

repeat(1000) {
     launch(CommonPool) { 
         for (task in channel) {
             // process task
         }
     }
}

[elizarov]

See also https://github.com/Kotlin/kotlinx.coroutines/issues/172

[trathschlag]

Nice, this is super easy! Thanks