버퍼 채널*1
지금까지 표시된 채널에는 버퍼가 없습니다.
버퍼링되지 않은 채널은 발신자와 수신자가 만날 때 값을 전송합니다.
이것은 랑데부 포인트라고도 합니다.
*2 만약에 보내다먼저 실행, 받다실행될 때까지 일시 중지됩니다.
만약에 받다먼저 실행, 보내다실행될 때까지 일시 중지됩니다.
Channel() 팩토리 함수와 프로덕션 빌더는 선택적으로 버퍼 크기를 사용하여 크기를 조정할 수 있습니다.
용량 파라미터를 받습니다.
BlockingQueue와 마찬가지로 Buffer는 용량버퍼가 가득 차면 발신자가 일시 중지*3 및 중지*4 전에 여러 요소를 보낼 수 있습니다.
다음 코드의 동작을 살펴보겠습니다.
val channel = Channel<Int>(4) // create buffered channel
val sender = launch { // launch sender coroutine
repeat(10) {
println("Sending $it") // print before sending each element
channel.send(it) // will suspend when buffer is full
}
}
// don't receive anything... just wait....
delay(1000)
sender.cancel() // cancel sender coroutine전체 코드는 여기허용
이것은 용량4개의 Buffered Channel을 사용하므로 Sending은 5번 출력된다.
Sending 0
Sending 1
Sending 2
Sending 3
Sending 4
처음 4개의 요소가 버퍼에 추가되고 5번째를 보내려고 하면 발신자가 중단됩니다.
다음 내용은 독자의 이해를 위해 번역자가 추가한 내용입니다.
*하나. 버퍼는 첫 번째 입력이 대기 중인 동안 다음 입력이 저장되는 공간입니다.
버퍼링된 채널은 첫 번째 입력이 처리되지 않는 동안 보내기를 통해 수신된 다음 입력을 저장할 공간이 있는 채널입니다.
*2. 원문은 (일명 랑데부)인데, 이해를 돕기 위해 따로 번역했습니다.
랑데부(Rendezvous)는 프랑스어로 ‘만나다’라는 뜻이다.
*3. capacity=0이 기본값인데 들어오자마자 멈춘다.
*4. 원문은 블록이지만 채널이 일시적으로 정지되어 중단으로 번역됩니다.
이 문서는 공식 코루틴 문서를 번역한 것입니다.
원래: 채널 – 버퍼링된 채널
원본 최종 편집: 2022년 9월 28일
채널이 같음
채널에서 보내기 및 받기 작업은 여러 코루틴이 호출되는 순서에 따라 공정합니다.
채널은 FIFO 구조로 제공되며, 먼저 받다호출된 코루틴에는 하나의 요소가 있습니다.
다음 예제에서는 “ping” 및 “pong”이라는 두 개의 코루틴이 공유됩니다.
테이블 채널을 통해 “공” 개체를 받습니다.
data class Ball(var hits: Int)
fun main() = runBlocking {
val table = Channel<Ball>() // a shared table
launch { player("ping", table) }
launch { player("pong", table) }
table.send(Ball(0)) // serve the ball
delay(1000) // delay 1 second
coroutineContext.cancelChildren() // game over, cancel them
}
suspend fun player(name: String, table: Channel<Ball>) {
for (ball in table) { // receive the ball in a loop
ball.hits++
println("$name $ball")
delay(300) // wait a bit
table.send(ball) // send the ball back
}
}전체 코드는 여기허용
“ping” 코루틴이 먼저 시작됩니다.
따라서 이 코루틴은 공을 먼저 받습니다.
“ping” 코루틴이 공을 다시 테이블로 보낸 후 즉시 다시 수신을 시작하더라도 “pong” 코루틴이 이미 듣고 있기 때문에 “pong” 코루틴이 공을 수신합니다.
ping Ball(hits=1)
pong Ball(hits=2)
ping Ball(hits=3)
pong Ball(hits=4)
간혹 사용하는 송신기의 특성상 채널이 정상적으로 동작하지 않을 수 있습니다.
자세한 내용은 이 문제보자. *하나
다음 내용은 독자의 이해를 위해 번역자가 추가한 내용입니다.
*하나. 이 문제는 실제로 자주 발생합니다.
이것은 하나의 스레드에서 여러 개의 코루틴을 실행할 때 문제가 되는 것 같습니다.
연산 중에 코루틴이 양보하면 스레드를 점유하고 있는 코루틴이 먼저 실행됩니다.
따라서 여러 개의 코루틴이 단일 스레드에서 실행되는 경우 채널에 대한 수신을 먼저 수행하는 사람은 무작위가 됩니다.
그 이유는 리시브를 통한 정지가 없기 때문입니다.
이 문서는 공식 코루틴 문서를 번역한 것입니다.
원본 최종 편집: 2022년 9월 28일
스톡 채널
티커 채널은 채널이 마지막으로 사용된 후 일정 시간이 경과한 후 유닛을 생성하는 특별한 랑데뷰 채널입니다.
이것은 그 자체로는 쓸모가 없어 보일 수 있지만 복잡한 시간 기반 프로덕션 파이프라인 블록 또는 창*1 또는 시간 종속 처리를 구축하는 데 유용합니다.
코드 레인을 선택하여 “온 틱” 작업을 수행할 수 있습니다.
이 채널을 만드세요 증권 시세 표시기 더 이상 요소를 받을 필요가 없음을 나타내는 데 사용할 수 있는 ReceiveChannel.cancel이라는 메서드를 사용합니다.
실제로 어떻게 작동하는지 봅시다:
fun main() = runBlocking<Unit> {
val tickerChannel = ticker(delayMillis = 100, initialDelayMillis = 0) // create ticker channel
var nextElement = withTimeoutOrNull(1) { tickerChannel.receive() }
println("Initial element is available immediately: $nextElement") // no initial delay
nextElement = withTimeoutOrNull(50) { tickerChannel.receive() } // all subsequent elements have 100ms delay
println("Next element is not ready in 50 ms: $nextElement")
nextElement = withTimeoutOrNull(60) { tickerChannel.receive() }
println("Next element is ready in 100 ms: $nextElement")
// Emulate large consumption delays
println("Consumer pauses for 150ms")
delay(150)
// Next element is available immediately
nextElement = withTimeoutOrNull(1) { tickerChannel.receive() }
println("Next element is available immediately after large consumer delay: $nextElement")
// Note that the pause between `receive` calls is taken into account and next element arrives faster
nextElement = withTimeoutOrNull(60) { tickerChannel.receive() }
println("Next element is ready in 50ms after consumer pause in 150ms: $nextElement")
tickerChannel.cancel() // indicate that no more elements are needed
}전체 코드는 여기허용
그러면 다음 줄이 인쇄됩니다.
Initial element is available immediately: kotlin.Unit
Next element is not ready in 50 ms: null
Next element is ready in 100 ms: kotlin.Unit
Consumer pauses for 150ms
Next element is available immediately after large consumer delay: kotlin.Unit
Next element is ready in 50ms after consumer pause in 150ms: kotlin.Unit티커는 소비자가 일시 중지하고 있음을 알고 있으며 기본 동작은 일시 중지가 발생할 때 다음 요소 생성을 지연하여 요소가 일정한 속도로 계속 생성
선택적 패턴 매개변수 TickerMode.FIXED_DELAY 두 요소 사이에 일정한 지연을 생성하도록 설정할 수 있습니다.
다음 내용은 독자의 이해를 위해 번역자가 추가한 내용입니다.
*하나. Windowing은 보낸 사람의 승인을 받지 않고 데이터를 계속 보내는 기술입니다.
이 문서는 공식 코루틴 문서를 번역한 것입니다.
원래: 채널 – 티커 채널
원본 최종 편집: 2022년 9월 28일