Producer-consumer

Channel ile producer-consumer deseni öğrenirsin.

Producer-consumer ve Channel

Channel, coroutine'ler arası veri aktarır. Producer send ile yazar, consumer receive veya for ile okur. Bu, producer-consumer deseninin temelidir.

Örnek: val ch = Channel<Int>(3); ch.send(1); ch.close(). Consumer tarafta for (v in ch) println(v). Channel(3) 3 elemanlık buffer sağlar; close akışı sonlandırır. Bu kalıp, paralel üretim ve tüketim için kullanılır.

Buffered ve rendezvous channel

Channel() varsayılan olarak rendezvous'dur; send karşılıklı buluşmaya kadar bekler. Channel(n) n elemanlık buffer verir; send buffer dolana kadar bekler.

Örnek: Channel<Int>() rendezvous, Channel<Int>(3) 3 bufferlı. Buffered channel, producer'ın consumer'dan bağımsız çalışmasına izin verir. close() ile channel kapatılır; consumer döngüsü sonlanır.

Uygulama Channel ile üç değer üret

main fonksiyonunu runBlocking ile aç. val ch = Channel<Int>(3) oluştur; 1, 2, 3 gönder, close() çağır. for (v in ch) println(v) ile değerleri yazdır.

Örnek çözümü göster

import kotlinx.coroutines.channels.Channel
import kotlinx.coroutines.runBlocking

fun main() = runBlocking {
    val ch = Channel<Int>(3)
    ch.send(1)
    ch.send(2)
    ch.send(3)
    ch.close()
    for (v in ch) println(v)
}

Kendini test et

Channel parçalarını eşle

Channel<Int>(3)

Buffered channel
send(1)

Üretim
close()

Akış sonu
for (v in ch)

Tüketim
Channel'i kapatmak ve akışı sonlandırmak için hangi metot kullanılır?
- stop()
- terminate()
- end()
- close()
Cevabı göster

close() — close() channel'ı kapatır ve tüketimi bitirir.

Channel tanımını tamamla

val ch = ____<Int>(3)

Cevabı göster

val ch = Channel<Int>(3)

Sıradaki ders: Rate limiter

Deneyiminizi Geliştiriyoruz

Çerez Tercihleri

Kesinlikle Gerekli Çerezler

Analitik Çerezler