elizarov
03/03/2017, 4:38 PMval requests = Channel<Request>()
2. Launch n
coroutines to process this channel:
repeat(n) {
launch(context) {
for (request in requests)
request.execute()
}
}
Done. You have a guarantee now that at most n
requests are processed concurrently.