dave08
05/08/2018, 11:37 AMval channel = Channel<ProcessingRequest>()
val processingPool = newThreadPool...
launch(processingPool) { for (request in channel) doProcessing(it) }
for ...
for ...
channel.sendBlocking(ProcessingRequest(...))