Unire i thread e raccogliere i risultati
Attenda i thread e raccolga l'output.
Unire i thread e raccogliere i risultati è una lezione Learn Rust Coding gratuita su CoddyKit. Questa è la lezione 4 di 4. Puoi leggere la lezione completa qui gratuitamente — poi esercitati direttamente nel browser con un editor di codice integrato e un tutor IA disponibile 24/7. Fa parte del percorso di apprendimento Learn Rust Coding, e i tuoi progressi si sincronizzano tra il web e l'app CoddyKit. Il corso Learn Rust Coding include 4 lezioni in totale.
Perché unire i thread?
Avviare un thread dà inizio al lavoro, ma di solito serve il suo risultato o almeno la certezza che sia terminato. Il join è il modo per attendere.
In questa lezione raccoglierà gli handle, eseguirà il join e riunirà i valori prodotti in una risposta finale.
join restituisce un Result
join restituisce un Result. In caso di successo contiene il valore restituito dalla closure; se un thread va in panic contiene un Err.
Chiamare unwrap restituisce direttamente il valore, ma propaga un panic se il thread ha avuto esito negativo.
use std::thread;
fn main() {
let h = thread::spawn(|| 7 * 6);
let value: i32 = h.join().unwrap();
println!("answer = {}", value);
}Raccogliere prima gli handle
Per eseguire i thread in parallelo, li avvii tutti prima di eseguire il join di uno qualsiasi. Inserisca ogni handle in un vettore man mano.
Se esegue il join all'interno del ciclo di spawn, ogni thread termina prima che inizi il successivo e si perde la concorrenza.
use std::thread;
fn main() {
let handles: Vec<_> = (0..4)
.map(|i| thread::spawn(move || i * i))
.collect();
for h in handles {
println!("{}", h.join().unwrap());
}
}Raccogliere i risultati in un Vec
Può eseguire il join di ogni handle e inserire i valori restituiti in un vettore dei risultati.
Qui sia l'ordine di spawn sia quello di join vanno da zero a tre, quindi il vettore dei risultati assume un ordine prevedibile.
use std::thread;
fn main() {
let handles: Vec<_> = (1..=4)
.map(|n| thread::spawn(move || n * 10))
.collect();
let results: Vec<i32> = handles
.into_iter()
.map(|h| h.join().unwrap())
.collect();
println!("{:?}", results);
}Sommare risultati paralleli
Una volta raccolti i risultati, può ridurli. Qui ogni thread calcola un valore parziale e main li somma.
Questa struttura map seguita da reduce è un modello comune di elaborazione parallela.
use std::thread;
fn main() {
let handles: Vec<_> = (1..=5)
.map(|n| thread::spawn(move || n * n))
.collect();
let total: i32 = handles
.into_iter()
.map(|h| h.join().unwrap())
.sum();
println!("total = {}", total);
}Dividere il lavoro in blocchi
Per dati più grandi, li divida in blocchi e assegni ogni blocco al proprio thread. Ogni thread restituisce una somma parziale.
Clonare ogni blocco in un Vec di proprietà consente al thread di possedere la propria porzione in modo sicuro.
use std::thread;
fn main() {
let data: Vec<i32> = (1..=10).collect();
let handles: Vec<_> = data
.chunks(5)
.map(|c| { let c = c.to_vec(); thread::spawn(move || c.iter().sum::<i32>()) })
.collect();
let total: i32 = handles.into_iter().map(|h| h.join().unwrap()).sum();
println!("{}", total);
}Gestire il panic di un thread
Se un worker potrebbe andare in panic, non usi unwrap alla cieca. Esegua il match sul Result restituito da join per gestire il percorso di errore.
In questo modo il thread principale rimane attivo anche quando un worker non riesce.
use std::thread;
fn main() {
let h = thread::spawn(|| {
if true { panic!("failed"); }
1
});
match h.join() {
Ok(v) => println!("got {}", v),
Err(_) => println!("thread panicked"),
}
}Raccogliere in un Vec condiviso
Anziché restituire valori, i thread possono inserirli in un Arc<Mutex<Vec>> condiviso. L'ordine diventa quindi non deterministico.
Dopo aver eseguito il join di tutti i thread, blocchi il vettore una sola volta per leggere ogni risultato raccolto.
use std::sync::{Arc, Mutex};
use std::thread;
fn main() {
let out = Arc::new(Mutex::new(vec![]));
let mut handles = vec![];
for i in 0..3 {
let o = Arc::clone(&out);
handles.push(thread::spawn(move || o.lock().unwrap().push(i)));
}
for h in handles { h.join().unwrap(); }
println!("{:?}", out.lock().unwrap());
}Thread con scope
thread::scope consente ai thread di prendere in prestito dati locali senza move o Arc. Lo scope garantisce che tutti i thread terminino prima di restituire il controllo.
Questo rende semplici e sicure le letture parallele di dati nello stack.
use std::thread;
fn main() {
let data = vec![1, 2, 3];
thread::scope(|s| {
s.spawn(|| println!("sum {}", data.iter().sum::<i32>()));
s.spawn(|| println!("len {}", data.len()));
});
}Restituire risultati dallo scope
Anche i thread con scope restituiscono valori tramite i propri handle. Esegua il join al loro interno per raccogliere i risultati.
Poiché lo scope blocca l'esecuzione fino al completamento, i dati presi in prestito rimangono validi per tutto il tempo.
use std::thread;
fn main() {
let nums = vec![4, 5, 6];
let total = thread::scope(|s| {
let h = s.spawn(|| nums.iter().sum::<i32>());
h.join().unwrap()
});
println!("total = {}", total);
}Non dimentichi il join
Se elimina un JoinHandle senza eseguire il join, il thread viene scollegato. Continua a essere eseguito, ma si perde il risultato e qualsiasi possibilità di attenderne la conclusione.
Il processo può anche terminare prima che un thread scollegato finisca. Esegua il join quando servono il risultato o la certezza del completamento.
Verifica rapida
Verifichi la Sua comprensione del join e della raccolta dei risultati.
Riepilogo
Ha imparato che join restituisce un Result contenente il valore o il panic di un thread. Avvii prima tutti i thread, quindi esegua il join per mantenere la concorrenza.
Può raccogliere i risultati in un Vec, ridurli oppure inserirli in un Arc<Mutex<Vec>> condiviso. I thread con scope prendono in prestito i dati locali in modo sicuro, mentre eliminare un handle scollega il thread.
Ora dispone degli strumenti fondamentali per gestire thread e stato condiviso in Rust.
Impara Rust con un tutor IA — gratis
Scrivi ed esegui vero codice nel tuo browser, ricevi aiuto istantaneo da un tutor IA disponibile 24/7, e riprendi da dove hai lasciato sul web o nell'app.
- Corsi
- 39
- Lezioni
- 144
Domande Frequenti
La lezione «Unire i thread e raccogliere i risultati» è gratuita?
Sì — il testo completo di «Unire i thread e raccogliere i risultati» è gratuito qui sul web. Per esercitarvi in modo interattivo (un editor di codice integrato e un tutor IA 24/7) e sbloccare il resto del corso Learn Rust Coding, passa a CoddyKit PRO. Il corso Learn Rust Coding include 4 lezioni in totale.
Cosa imparerò in «Unire i thread e raccogliere i risultati»?
Attenda i thread e raccolga l'output. Eserciti Learn Rust Coding con codice pratico che esegui direttamente nel browser, e un tutor IA 24/7 risponde alle tue domande mentre lavori sulla lezione.
Ho bisogno di esperienza per iniziare Learn Rust Coding?
Non è richiesta alcuna esperienza precedente. Learn Rust Coding su CoddyKit è strutturato per principianti e studenti avanzati, quindi puoi iniziare da qui o dall'inizio e procedere al tuo ritmo. Questa è la lezione 4 di 4.
Quanto tempo richiede la lezione «Unire i thread e raccogliere i risultati»?
La maggior parte delle lezioni CoddyKit richiede circa 5–10 minuti. Ogni lezione è breve e interattiva, quindi fai progressi costanti e riprendi esattamente da dove hai lasciato su web e app.
Posso scrivere ed eseguire codice in questa lezione Learn Rust Coding?
Sì. Ogni lezione Learn Rust Coding include un editor di codice integrato, quindi scrivi ed esegui codice reale direttamente nel tuo browser e ricevi feedback istantaneo dall'IA — nessuna configurazione locale necessaria.
Tutte le lezioni di questo corso
- Creare thread
- Spostare i dati nei thread
- Condividere con Arc e Mutex
- Unire i thread e raccogliere i risultati