Comprehensive Rust(Português do Brasil) 202412oneshot::Sender, } // Um trabalhador que escuta o trabalho em uma fila e o executa. async fn worker(mut work_queue: mpsc::Receiver ) { let mut iterations = 0; loop { tokio::select! { Some(work) expect("falha ao esperar pela resposta") } async fn main() { let (tx, rx) = mpsc::channel(10); spawn(worker(rx)); for i in 0..100 { let resp = do_work(&tx, i).await; println!("resultado do trabalho para a 0 码力 | 389 页 | 1.05 MB | 10 月前3
共 1 条
- 1