Kotlin Academy · 강의

채널 기초: send, receive 및 close

채널을 만들고 값을 보내고 받으며 올바르게 닫아 보세요.

레슨 1/413개 단계

채널 기초: send, receive 및 close은(는) CoddyKit의 무료 Kotlin Academy 강의입니다. 이것은 4개 중 1번째 강의입니다. 아래에서 전체 강의를 무료로 읽을 수 있으며, 내장 코드 에디터와 24/7 AI 튜터와 함께 브라우저에서 직접 실습할 수 있습니다. 이 강의는 Kotlin Academy 학습 경로의 일부이며, 진행 상황이 웹과 CoddyKit 앱에 동기화됩니다. Kotlin Academy 강의에는 총 4개의 강의가 포함되어 있습니다.

채널이란 무엇입니까

Channel은 코루틴 간 통신을 위한 기본 요소입니다. 차단형 대기열과 비슷하지만 일시 중단된다는 점이 다릅니다. 한쪽에서 보내면 다른 쪽에서 받는 파이프라고 생각하십시오.

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

send(value)는 수신자가 준비될 때까지 일시 중단됩니다. receive()는 값을 사용할 수 있을 때까지 일시 중단됩니다.

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

채널 닫기

channel.close()는 더 이상 값을 보내지 않는다는 신호를 보냅니다. 수신자는 버퍼에 남은 값을 받은 다음 for 루프를 종료합니다.

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

isClosedForSend(더 이상 보낼 수 없음)와 isClosedForReceive(모든 값을 소비함)로 채널 상태를 확인하십시오.

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 빌더

produce { }는 생산자 코루틴을 생성하고 ReceiveChannel을 반환하는 코루틴 빌더입니다. 블록이 끝나면 채널이 자동으로 닫힙니다.

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 확장

consumeEach { }는 채널을 순회하며 블록에서 예외가 발생하면 채널을 취소하여 리소스 누수를 방지합니다.

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

일시 중단되지 않는 대안으로 trySend/tryReceive는 일시 중단 없이 즉시 ChannelResult를 반환합니다.

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

팬아웃: 여러 소비자

여러 코루틴이 같은 채널에서 값을 받아 작업을 분배할 수 있습니다. 이를 팬아웃 패턴이라고 합니다.

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

팬인: 여러 생산자

여러 코루틴이 같은 채널로 값을 보내 출력을 병합할 수 있습니다. 이를 팬인 패턴이라고 합니다.

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

파이프라인 패턴

채널을 파이프라인으로 연결하여 각 단계가 한 채널에서 읽고 다른 채널에 쓰도록 하십시오. 데이터 처리 작업 흐름에 적합합니다.

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

채널과 플로우

채널은 핫하고 상태를 유지합니다. 즉, 소비와 관계없이 독립적으로 존재합니다. 플로우는 콜드하고 선언적이며, 수집할 때마다 다시 시작됩니다. 데이터 스트림에는 플로우를 우선 사용하고, 생산자와 소비자 간 통신에는 채널을 사용하십시오.

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

빠른 확인

channel.close()을 호출하면 어떻게 됩니까?

인터랙티브 레슨에서 답해보세요

복습

send와 receive는 상대편이 준비될 때까지 일시 중단됩니다. close()는 완료를 알립니다. 자동으로 닫히는 생산자에는 produce, 안전한 순회에는 consumeEach를 사용하고, 팬아웃/팬인 패턴에는 채널을 사용하십시오.

무료로 시작

AI 튜터와 함께 Kotlin을(를) 배우세요 — 무료

브라우저에서 실제 코드를 작성하고 실행하며, 24/7 AI 튜터로부터 즉각적인 도움을 받고, 웹이나 앱에서 중단한 부분부터 계속 학습하세요.

코스: 51
레슨: 203

무료로 학습 시작 전체 코스 보기

자주 묻는 질문

“채널 기초: send, receive 및 close” 강의는 무료인가요?

네 — “채널 기초: send, receive 및 close” 전체 내용을 이 웹사이트에서 무료로 읽을 수 있습니다. 인터랙티브하게 실습하려면(내장 코드 에디터와 24/7 AI 튜터), CoddyKit PRO로 업그레이드하면 Kotlin Academy 강의 전체를 잠금 해제할 수 있습니다. Kotlin Academy 강의에는 총 4개의 강의가 포함되어 있습니다.

“채널 기초: send, receive 및 close”에서 뭘 배우나요?

채널을 만들고 값을 보내고 받으며 올바르게 닫아 보세요. 브라우저에서 직접 실행하는 실습 코드로 Kotlin Academy을(를) 배우며, 24/7 AI 튜터가 강의를 진행하면서 질문에 답변해줍니다.

Kotlin Academy을(를) 시작하는 데 경험이 필요한가요?

사전 경험은 필요하지 않습니다. CoddyKit의 Kotlin Academy은(는) 초급자부터 고급 학습자까지를 위해 구성되어 있으므로, 여기서 시작하거나 처음부터 시작할 수 있으며 자신의 속도대로 진행할 수 있습니다. 이것은 4개 중 1번째 강의입니다.

“채널 기초: send, receive 및 close” 강의는 얼마나 걸리나요?

대부분의 CoddyKit 강의는 약 5~10분이 소요됩니다. 각 강의는 간결하고 인터랙티브하여 꾸준한 진행이 가능하며, 웹과 앱에서 중단한 부분부터 바로 시작할 수 있습니다.

이 Kotlin Academy 강의에서 코드를 작성하고 실행할 수 있나요?

네. 모든 Kotlin Academy 강의에는 내장 코드 에디터가 포함되어 있으므로, 브라우저에서 바로 실제 코드를 작성하고 실행한 후 즉시 AI 피드백을 받을 수 있습니다 — 로컬 설정이 필요 없습니다.

이 강의의 모든 강의

← Kotlin Academy(으)로 돌아가기