3

Kotlin - coroutine channels

 2 years ago
source link: http://mussatto.github.io/kotlin/channel/coroutine/consumer/queue/2020/08/13/kotlin-channels.html
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.

“Stuff I always forget how to do and have to google it”

Step 1 - create channel reader or processor (in parallel)

private fun CoroutineScope.createProcessorJob(channel: Channel<String>): Job {
    return launch {
        //process untill channel closed
        for (message in channel) {
            println("PROCESSOR: processing ->$message<-")
            Thread.sleep(500)
        }
        println("OMG, THE CHANNEL IS CLOSED!")
    }
}

Step 2 - create channel sender or producer (in parallel)

private fun CoroutineScope.sendListToChannel(list: List<String>, channel: Channel<String>): MutableList<Job> {
    val senderJobs = mutableListOf<Job>()
    list.forEach {
        val job = launch {
            channel.send("Hey processor, process $it")
            println("Sending super duper fast, until the capacity is hit.")
        }
        senderJobs.add(job)

    }
    return senderJobs
}

Orchestrate everything

val list = listOf("A", "B", "C", "D", "E", "F", "G", "H", "I", "J", "K", "L", "M", "N", "O")
val channel = Channel<String>(5)
// wait for the whole test to finish
runBlocking {

    coroutineScope{
        val processorJob = createProcessorJob(channel)
        val senderJobs = sendListToChannel(list, channel)
        senderJobs.joinAll()
        channel.close()
        processorJob.join()
    }

}

Source code: Here


report

Recommend

About Joyk


Aggregate valuable and interesting links.
Joyk means Joy of geeK