Kotlin Academy · leksjon

Grunnleggende om Channel: send, receive og close

Opprett channels, send og motta verdier, og lukk dem riktig.

Leksjon 1 av 413 trinn

Grunnleggende om Channel: send, receive og close er en gratis leksjon i Kotlin Academy på CoddyKit. Dette er leksjon 1 av 4. Du kan lese valgfritt 3 leksjoner fra denne læringsstien gratis i sin helhet – deretter låser CoddyKit PRO opp alle leksjoner, samt praktisk øving med en innebygd kodeeditor og en AI-veileder som er tilgjengelig døgnet rundt. Den er en del av læringsløpet i Kotlin Academy, og fremdriften din synkroniseres mellom nettet og CoddyKit-appen. Kurset i Kotlin Academy inneholder totalt 4 leksjoner.

Hva er en kanal?

En Channel er en korutineprimitiv for kommunikasjon mellom korutiner — omtrent som en blokkerende kø, men med suspendering. Tenk på den som et rør: Én side sender, og den andre mottar.

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 og receive

send(value) suspenderes til mottakeren er klar. receive() suspenderes til en verdi er tilgjengelig.

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")
}

Lukke en kanal

channel.close() signaliserer at det ikke vil bli sendt flere verdier. Mottakerne får de gjenværende bufrede verdiene, og deretter avsluttes for-løkken.

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

Kontroller kanalens tilstand med isClosedForSend (flere sendinger er ikke tillatt) og isClosedForReceive (alle verdier er lest).

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}")
}

produce-byggeren

produce { } er en korutinebygger som oppretter en produsentkorutine og returnerer en ReceiveChannel. Kanalen lukkes automatisk når blokken avsluttes.

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
}

consumeEach-utvidelsen

consumeEach { } går gjennom en kanal og avbryter den hvis blokken kaster et unntak, slik at lekkasjer unngås.

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 og trySend

Alternativer som ikke suspenderes: trySend / tryReceive returnerer en ChannelResult umiddelbart uten å suspendere.

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: Flere forbrukere

Flere korutiner kan motta fra den samme kanalen og fordele arbeidet — et fan-out-mønster.

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: Flere produsenter

Flere korutiner kan sende til den samme kanalen og slå sammen resultatene — et fan-in-mønster.

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()
    }
}

Pipeline-mønsteret

Kjed sammen kanaler i en pipeline der hvert trinn leser fra én kanal og skriver til en annen — godt egnet for arbeidsflyter innen databehandling.

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()
}

Kanal kontra Flow

Kanaler er hotte og tilstandsfulle — de eksisterer uavhengig av innsamling. Flow-er er kalde og deklarative — de starter på nytt ved hver innsamling. Foretrekk Flow for datastrømmer, og bruk Channel for kommunikasjon mellom produsenter og forbrukere.

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") }

Kort sjekk

Hva skjer når channel.close() kalles?

Besvar den i den interaktive leksjonen

Oppsummering

send og receive suspenderes til den andre siden er klar. close() signaliserer at arbeidet er fullført. Bruk produce for produsenter som lukker seg selv, consumeEach for trygg iterasjon, og kanaler for fan-out- og fan-in-mønstre.

Gratis å komme i gang

Lær deg Kotlin med en AI-veileder – gratis

Skriv og kjør ekte kode i nettleseren, få umiddelbar hjelp fra en AI-veileder som er tilgjengelig døgnet rundt, og fortsett der du slapp – på nettet eller i appen.

Kurs: 51
Leksjoner: 203

Start læringen gratis Se hele kurset

Ofte stilte spørsmål

Er leksjonen «Grunnleggende om Channel: send, receive og close» gratis?

Ja – du kan lese valgfritt 3 av leksjonene i læringsstien Kotlin Academy, inkludert «Grunnleggende om Channel: send, receive og close», gratis i sin helhet her på nettet. Deretter låser CoddyKit PRO opp alle leksjoner, samt interaktiv øving med en innebygd kodeeditor og en AI-veileder som er tilgjengelig døgnet rundt. Kurset i Kotlin Academy inneholder totalt 4 leksjoner.

Hva lærer jeg i «Grunnleggende om Channel: send, receive og close»?

Opprett channels, send og motta verdier, og lukk dem riktig. Du øver på Kotlin Academy med praktisk kode som du kjører direkte i nettleseren, mens en AI-veileder som er tilgjengelig døgnet rundt, svarer på spørsmålene dine mens du jobber deg gjennom leksjonen.

Trenger jeg erfaring for å begynne med Kotlin Academy?

Ingen tidligere erfaring er nødvendig. Kotlin Academy på CoddyKit er lagt opp for både nybegynnere og viderekomne, så De kan begynne her eller helt fra start og lære i Deres eget tempo. Dette er leksjon 1 av 4.

Hvor lang tid tar leksjonen «Grunnleggende om Channel: send, receive og close»?

De fleste CoddyKit-leksjoner tar omtrent 5–10 minutter. Hver leksjon er kort og interaktiv, slik at De gjør jevne fremskritt og kan fortsette akkurat der De slapp – både på nettet og i appen.

Kan jeg skrive og kjøre kode i denne Kotlin Academy-leksjonen?

Ja. Alle Kotlin Academy-leksjoner har en innebygd kodeeditor, slik at De kan skrive og kjøre ekte kode direkte i nettleseren og få umiddelbar tilbakemelding fra AI – uten lokal konfigurering.

Alle leksjonene i dette kurset

Grunnleggende om Channel: send, receive og close
Channel-typer: Rendezvous, Buffered, Conflated, Unlimited
Mutex og Semaphore for delt tilstand
Aktører og strukturert tilstandsbehandling

← Tilbake til Kotlin Academy