mpsc kanalı

std::sync::mpsc ile kanal oluşturmayı öğrenirsin.

mpsc kanalı

Kanallar, thread'lerin veriyi paylaşmak yerine mesajla iletişim kurmasını sağlar: "Belleği paylaşarak iletişim kurma; iletişim kurarak belleği paylaş." mpsc (multiple producer, single consumer) bir gönderici (tx) ve bir alıcı (rx) verir:

use std::sync::mpsc;

let (tx, rx) = mpsc::channel();
thread::spawn(move || {
    for i in 1..=3 {
        tx.send(format!("mesaj {i}")).unwrap();
    }
});
for m in rx {                // tx bırakılınca döngü biter
    println!("{m}");
}

Gönderilen değerin sahipliği alıcıya geçer; gönderen artık ona erişemez.

Kanal bir yineleyicidir

for m in rx (ya da rx.iter()) her mesajda recv çağırır ve tüm göndericiler bırakıldığında biter. Gönderici thread'in closure'ı bitince tx otomatik bırakılır; bu yüzden döngü kendiliğinden sona erer.

// mesaj sırası, tek bir gönderici için korunur
// mesaj 1
// mesaj 2
// mesaj 3

Uygulama Mesajlar

Bir kanal aç. Ayrı bir thread mesaj 1, mesaj 2, mesaj 3 metinlerini göndersin; ana thread for m in rx ile her birini yazdırsın.

Örnek çözümü göster

use std::sync::mpsc;
use std::thread;

fn main() {
    let (tx, rx) = mpsc::channel();
    thread::spawn(move || {
        for i in 1..=3 {
            tx.send(format!("mesaj {i}")).unwrap();
        }
    });
    for m in rx {
        println!("{}", m);
    }
}

Kendini test et

Gönderdikten sonra değeri kullanmaya çalışmak (<code>tx.send(s); println!("{s}")</code>) ne olur?
- Çalışır
- Panic
- Boş metin yazar
- E0382: s kanala taşındı
Cevabı göster

E0382: s kanala taşındı — Sahiplik aktarımı, iki thread'in aynı veriyi aynı anda değiştirmesini imkânsız kılar.

Kanal aç

let (tx, rx) = mpsc::____();

Cevabı göster

let (tx, rx) = mpsc::channel();

Parça ve görevi

tx

Gönderici
rx

Alıcı
tx.send(v)

Sahipliği aktarır
for m in rx

Göndericiler kapanana kadar

Sıradaki ders: send ve recv

Deneyiminizi Geliştiriyoruz

Çerez Tercihleri

Kesinlikle Gerekli Çerezler

Analitik Çerezler