tokio::sync

tokio::sync ile asenkron senkronizasyon araçlarını öğrenirsin.

tokio::sync

tokio::sync görevler arası eşzamanlama araçları sunar: Mutex, RwLock (kilidi beklerken thread'i bloke etmez), mpsc, broadcast, watch ve tek seferlik yanıt için oneshot:

let (tx, rx) = tokio::sync::oneshot::channel();
tokio::spawn(async move {
    tx.send(6 * 7).unwrap();
});
println!("{}", rx.await.unwrap());   // 42

oneshot, "bir göreve iş ver, sonucunu tek bir mesajla al" deseni için idealdir.

std karşılığı: tek mesajlık kanal

Standart kütüphanede ayrı bir oneshot yoktur, ama tek mesaj gönderilen bir mpsc kanalı aynı işi görür:

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

let (tx, rx) = mpsc::channel();
thread::spawn(move || {
    tx.send(6 * 7).unwrap();
});
println!("{}", rx.recv().unwrap());

recv mesaj gelene kadar bekler; gönderici mesaj göndermeden bırakılırsa Err döner.

Uygulama Tek seferlik yanıt

mpsc::channel ile bir kanal aç. Ayrı bir thread 6 * 7 sonucunu göndersin; ana thread recv ile alıp 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 || {
        tx.send(6 * 7).unwrap();
    });
    println!("{}", rx.recv().unwrap());
}

Kendini test et

Async kodda <code>std::sync::Mutex</code> ne zaman kabul edilebilir?
- Hiçbir zaman
- Her zaman
- Yalnızca tek thread'de
- Kilit kısa tutuluyorsa ve .await boyunca elde tutulmuyorsa
Cevabı göster

Kilit kısa tutuluyorsa ve .await boyunca elde tutulmuyorsa — Std mutex'i .await boyunca tutmak hem bloke edebilir hem de Future'ı Send olmaktan çıkarır; bu durumda tokio::sync::Mutex gerekir.

Mesaj bekle

let (tx, rx) = mpsc::channel();
thread::spawn(move || tx.send(42).unwrap());
let n = rx.____().unwrap();

Cevabı göster

let (tx, rx) = mpsc::channel();
thread::spawn(move || tx.send(42).unwrap());
let n = rx.recv().unwrap();

Araç ve kullanım

oneshot

Tek yanıt
mpsc

Çok üretici, tek tüketici
broadcast

Herkese yayın
watch

Son değeri izle

Sıradaki ders: tokio::fs

Deneyiminizi Geliştiriyoruz

Çerez Tercihleri

Kesinlikle Gerekli Çerezler

Analitik Çerezler