A modern programming language that makes developers happier.

kotlinlang

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?

Smth like this:
```
repeat(1000) {
     launch(CommonPool) { 
         for (task in channel) {
             // process task
         }
     }
}
```

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