send ve recv

send ve recv ile mesajlaşmayı öğrenirsin.

send ve recv

Her iki işlem de karşı tarafın kapanmasını bildirebilir:

tx.send(v) alıcı bırakılmışsa Err(SendError(v)) döndürür ve değeri geri verir.
rx.recv() mesaj gelene kadar bekler; tüm göndericiler bırakılmışsa ve kanal boşsa Err(RecvError) döndürür.

let (tx, rx) = mpsc::channel::<i32>();
drop(rx);
println!("{}", tx.send(1).is_err());   // true: dinleyen yok

Bu hatalar, bir thread'in diğerinin bittiğini anlamasının temiz yoludur.

Kapanmayı ele almak

Bir işçi, ana thread kapandığında sessizce durmalıdır:

thread::spawn(move || loop {
    let veri = hesapla();
    if tx.send(veri).is_err() {
        break;   // alıcı gitti, çalışmayı bırak
    }
});

recv tarafında da while let Ok(m) = rx.recv() deseni aynı işi görür.

Uygulama Kapanma hataları

Bir kanalın alıcısını bırakıp send(1).is_err() sonucunu yazdır. Başka bir kanalın göndericisini bırakıp recv() sonucunu {:?} ile yazdır.

Örnek çözümü göster

use std::sync::mpsc;

fn main() {
    let (tx, rx) = mpsc::channel::<i32>();
    drop(rx);
    println!("{}", tx.send(1).is_err());
    let (tx2, rx2) = mpsc::channel::<i32>();
    drop(tx2);
    println!("{:?}", rx2.recv());
}

Kendini test et

Neden <code>send</code> hata durumunda değeri geri verir?
- Gelenek
- Vermez
- Değer kaybolmasın; başka bir yere gönderilebilir ya da kaydedilebilir
- Bellek sızıntısını önlemek için
Cevabı göster

Değer kaybolmasın; başka bir yere gönderilebilir ya da kaydedilebilir — SendError(v).0 ile değere geri ulaşılır.

Alıcı kapandı mı?

if tx.send(veri).____() {
    break;
}

Cevabı göster

if tx.send(veri).is_err() {
    break;
}

Durum ve sonuç

rx bırakıldı + send

Err(SendError(v))
tx bırakıldı + recv (boş)

Err(RecvError)
Mesaj var + recv

Ok(mesaj)
while let Ok(m) = rx.recv()

Kapanınca biter

Sıradaki ders: Birden çok üretici

Deneyiminizi Geliştiriyoruz

Çerez Tercihleri

Kesinlikle Gerekli Çerezler

Analitik Çerezler