Basisprincipes van Channel: send, receive en close
Maak channels, verzend en ontvang waarden en sluit ze correct.
Basisprincipes van Channel: send, receive en close is een gratis Kotlin Academy-les op CoddyKit. Dit is les 1 van 4. Je kunt 3 lessen uit dit leerpad gratis volledig lezen — daarna ontgrendelt CoddyKit PRO alle lessen, plus praktische oefeningen met een ingebouwde code-editor en een AI-tutor die 24/7 beschikbaar is. Deze les maakt deel uit van het leertraject Kotlin Academy. Je voortgang wordt gesynchroniseerd op het web en in de CoddyKit-app. De cursus Kotlin Academy bevat in totaal 4 lessen.
Wat is een kanaal?
Een Channel is een coroutineprimitief voor communicatie tussen coroutines — vergelijkbaar met een blokkerende wachtrij, maar dan onderbreekbaar. Zie het als een pijp: de ene kant verzendt en de andere ontvangt.
import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*
fun main() = runBlocking {
val channel = Channel<Int>()
launch {
for (i in 1..5) channel.send(i)
channel.close()
}
for (x in channel) println(x) // 1 2 3 4 5
}send en receive
send(value) wordt onderbroken totdat de ontvanger klaar is. receive() wordt onderbroken totdat er een waarde beschikbaar is.
import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*
fun main() = runBlocking {
val ch = Channel<String>()
launch {
ch.send("ping")
println("sent")
}
val msg = ch.receive()
println("received: $msg")
}Een kanaal sluiten
channel.close() geeft aan dat er geen waarden meer worden verzonden. Ontvangers krijgen de resterende gebufferde waarden; daarna eindigt de for-lus.
import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*
fun main() = runBlocking {
val ch = Channel<Int>(3)
launch {
repeat(3) { ch.send(it) }
ch.close() // signal done
}
for (v in ch) println(v) // 0 1 2, then loop ends
println("Channel consumed")
}isClosedForSend / isClosedForReceive
Controleer de kanaalstatus met isClosedForSend (verzenden is niet meer toegestaan) en isClosedForReceive (alle waarden zijn verwerkt).
import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*
fun main() = runBlocking {
val ch = Channel<Int>()
launch {
ch.send(1)
ch.close()
}
println(ch.receive())
println("isClosedForReceive: ${ch.isClosedForReceive}")
}De builder produce
produce { } is een coroutinebouwer die een producent-coroutine maakt en een ReceiveChannel retourneert. Het kanaal wordt automatisch gesloten wanneer het blok eindigt.
import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*
fun CoroutineScope.squares(n: Int) = produce<Int> {
for (i in 1..n) send(i * i)
}
fun main() = runBlocking {
val sq = squares(5)
for (v in sq) println(v) // 1 4 9 16 25
}De extensie consumeEach
consumeEach { } doorloopt een kanaal en annuleert het wanneer het blok een fout veroorzaakt, zodat lekken worden voorkomen.
import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*
fun main() = runBlocking {
val ch = produce<String> {
send("a"); send("b"); send("c")
}
ch.consumeEach { println(it) }
}tryReceive en trySend
Niet-onderbrekende alternatieven: trySend / tryReceive retourneren onmiddellijk een ChannelResult zonder de uitvoering te onderbreken.
import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*
fun main() = runBlocking {
val ch = Channel<Int>(1)
val sendResult = ch.trySend(42)
println("Sent: ${sendResult.isSuccess}")
val recvResult = ch.tryReceive()
println("Got: ${recvResult.getOrNull()}")
}Fan-out: meerdere consumenten
Meerdere coroutines kunnen uit hetzelfde kanaal ontvangen en zo het werk verdelen — een fan-outpatroon.
import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*
fun main() = runBlocking {
val tasks = produce { repeat(6) { send(it) } }
repeat(3) { worker ->
launch {
for (task in tasks) {
println("Worker $worker: task $task")
}
}
}
}Fan-in: meerdere producenten
Meerdere coroutines kunnen naar hetzelfde kanaal verzenden en zo hun uitvoer samenvoegen — een fan-inpatroon.
import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*
fun main() = runBlocking {
val results = Channel<String>()
repeat(3) { i ->
launch { results.send("result-$i") }
}
launch {
repeat(3) { println(results.receive()) }
results.close()
}
}Pijplijnpatroon
Koppel kanalen tot een pijplijn waarin elke fase uit het ene kanaal leest en naar het andere schrijft — ideaal voor workflows voor gegevensverwerking.
import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*
fun CoroutineScope.numbers() = produce { for (i in 1..5) send(i) }
fun CoroutineScope.doubled(input: ReceiveChannel<Int>) = produce { for (v in input) send(v * 2) }
fun main() = runBlocking {
val nums = numbers()
val doubled = doubled(nums)
for (v in doubled) println(v) // 2 4 6 8 10
coroutineContext.cancelChildren()
}Channel versus Flow
Channels zijn hot en hebben een status — ze bestaan onafhankelijk van het verbruik. Flows zijn cold en declaratief — ze starten opnieuw bij elke verzamelbewerking. Geef de voorkeur aan Flow voor gegevensstromen en gebruik Channel voor communicatie tussen producent en consument.
import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*
import kotlinx.coroutines.flow.*
// Flow (cold): each collect() re-runs the block
// Channel (hot): shared; multiple receivers share the same stream
fun main() = runBlocking { println("Flow = cold; Channel = hot") }Korte controle
Wat gebeurt er wanneer je channel.close() aanroept?
Samenvatting
send en receive worden onderbroken totdat de andere kant klaar is. close() geeft voltooiing aan. Gebruik produce voor producenten die zichzelf sluiten, consumeEach voor veilig doorlopen en kanalen voor fan-out-/fan-inpatronen.
Leer Kotlin met een AI-tutor — gratis
Schrijf echte code en voer die uit in je browser, krijg direct hulp van een AI-tutor die 24/7 beschikbaar is en ga verder waar je gebleven bent op het web of in de app.
- Cursussen
- 51
- Lessen
- 203
Veelgestelde vragen
Is de les “Basisprincipes van Channel: send, receive en close” gratis?
Ja — je kunt hier op het web alle 3 lessen van het leerpad Kotlin Academy, waaronder “Basisprincipes van Channel: send, receive en close”, gratis volledig lezen. Daarna ontgrendelt CoddyKit PRO alle lessen, plus interactieve oefeningen met een ingebouwde code-editor en een AI-tutor die 24/7 beschikbaar is. De cursus Kotlin Academy bevat in totaal 4 lessen.
Wat leer ik in “Basisprincipes van Channel: send, receive en close”?
Maak channels, verzend en ontvang waarden en sluit ze correct. Je oefent met Kotlin Academy door code rechtstreeks in de browser uit te voeren. Een AI-begeleider die 24/7 beschikbaar is beantwoordt je vragen terwijl je de les doorwerkt.
Heb ik ervaring nodig om met Kotlin Academy te beginnen?
Ervaring vooraf is niet nodig. Kotlin Academy op CoddyKit is opgebouwd voor beginners tot gevorderden, zodat je hier of bij het begin kunt starten en in je eigen tempo kunt leren. Dit is les 1 van 4.
Hoe lang duurt de les “Basisprincipes van Channel: send, receive en close”?
De meeste lessen van CoddyKit duren ongeveer 5–10 minuten. Elke les is kort en interactief, zodat je gestaag vooruitgaat en op het web en in de app precies verdergaat waar je was gebleven.
Kan ik code schrijven en uitvoeren in deze les over Kotlin Academy?
Ja. Elke les over Kotlin Academy bevat een ingebouwde code-editor, zodat je rechtstreeks in je browser echte code kunt schrijven en uitvoeren en direct feedback van AI krijgt — lokale installatie is niet nodig.
Alle lessen in deze cursus
- Basisprincipes van Channel: send, receive en close
- Channeltypen: Rendezvous, Buffered, Conflated, Unlimited
- Mutex en Semaphore voor gedeelde status
- Actors en gestructureerd statusbeheer