rust多线程利用通道mpsc(channel)实现多发送单接收的示例

Admin | 2023-12-4 20:17:00 | 被阅次数 | 1549

温馨提示!

如果未能解决您的问题，请点击搜索；登陆可复制文章，点击登陆

在RUST语言中，可以通过std::threadg构造多线程，并通过td::sync::mpsc实现通道中的多发送及单接收的功能。

use std::sync::mpsc;

use std::thread;
use std::time::Duration;

fn main() {
let (tx, rx) = mpsc::channel();
let mut haddles =vec![];
for i in 1..11{
let m = i.clone();
let tx1 = tx.clone();
let haddle = thread::spawn(move || {
tx1.send(format!("the number is {}",m)).unwrap();
});
haddles.push(haddle);
}
for h in haddles{
h.join().unwrap();
}
drop(tx);
// while let Ok(msg)=rx.recv(){
// println!("{}",msg);
// }
let mut c:i32=0;
for x in rx{
println!("{}",x);
c+=1;
thread::sleep(Duration::from_secs(2));
}
println!("一共收到{c}个信息");
println!("子线程主线程全部结束。");
}
/*
the number is 1
the number is 5
the number is 2
the number is 3
the number is 6
the number is 7
the number is 9
the number is 8
the number is 10
the number is 4
一共收到10个信息
子线程主线程全部结束。
*/

该杂文来自：最新技术

上一篇：rust之trait与impl与Box与dyn的联合示例

下一篇：rust匿名函数之Fn,FnMut,FnOnce的使用