Snippet

Thread-basierte Nebenliufigkeit mit std::thread und Channels

Rust's std::thread Modul ermöglicht die Erstellung nativer OS-Threads, und mpsc (Multi-Producer, Single-Consumer) Channels ermöglichen sichere Kommunikation zwischen Threads. Der Channel besteht aus einem Sender (tx) und Empfanger (rx). Die spawn-Funktion erstellt einen neuen Thread, und move erlaubt der Closure Besitz von erfassten Variablen zu übernehmen (tx in diesem Fall). Nachrichten, die durch den Channel gesendet werden, sind garantiert ohne Data Races zugestellt. Der Empfanger-Iterator blockiert bis Nachrichten verfugbar sind, was ihn ideal fur die Koordination zwischen Threads macht.

snippet.rs

rust

use std::thread;
use std::sync::mpsc;
use std::time::Duration;
 
fn main() {
    let (tx, rx) = mpsc::channel();
 
    let handle = thread::spawn(move || {
        for i in 1..=5 {
            println!("Thread: sending {}", i);
            tx.send(i).unwrap();
            thread::sleep(Duration::from_millis(100));
        }
    });
 
    for received in rx.iter().take(5) {
        println!("Main: received {}", received);
    }
 
    handle.join().unwrap();
    println!("Thread completed successfully");
}

Erklärung

use std::thread;

Importiere thread Modul zum Erstellen nativer OS-Threads

use std::sync::mpsc;

Importiere mpsc (Multi-Producer Single-Consumer) Channel-Primitive

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

Erstelle Channel-Paar: Sender- und Empfanger-Endpunkte

let handle = thread::spawn(move || {

Erstelle neuen Thread, move übertragt tx-Besitz in die Closure

for i in 1..=5 {

Schleife 5 Mal mit inkrementierenden Integern

tx.send(i).unwrap();

Sende Wert durch Channel, unwrap behandelt Send-Fehler

thread::sleep(Duration::from_millis(100));

Simuliere Arbeit mit 100ms Pause zwischen Sendevorgangen

for received in rx.iter().take(5) {

Iteriere uber Channel mit take(5) um genau 5 Nachrichten zu verarbeiten

println!("Main: received {}", received);

Drucke jeden empfangenen Wert im Haupt-Thread

handle.join().unwrap();

Warte auf beendeten Thread, unwrap Join-Ergebnis

println!("Thread completed successfully");

Bestatigungsnachricht nach Thread-Beendigung

Vorheriges Snippet Nächstes Snippet

Mehr Rust-Übungen für Fortgeschrittene →

Thread-basierte Nebenliufigkeit mit std::thread und Channels

Verwandt