mirror of https://github.com/KaiserY/trpl-zh-cn
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
47 lines
955 B
47 lines
955 B
3 years ago
|
use std::sync::mpsc;
|
||
|
|
use std::thread;
|
||
|
|
use std::time::Duration;
|
||
|
|
|
||
|
|
fn main() {
|
||
|
|
// ANCHOR: here
|
||
|
|
// --snip--
|
||
|
|
|
||
|
|
let (tx, rx) = mpsc::channel();
|
||
|
|
|
||
|
|
let tx1 = tx.clone();
|
||
|
|
thread::spawn(move || {
|
||
|
|
let vals = vec![
|
||
|
|
String::from("hi"),
|
||
|
|
String::from("from"),
|
||
|
|
String::from("the"),
|
||
|
|
String::from("thread"),
|
||
|
|
];
|
||
|
|
|
||
|
|
for val in vals {
|
||
|
|
tx1.send(val).unwrap();
|
||
|
|
thread::sleep(Duration::from_secs(1));
|
||
|
|
}
|
||
|
|
});
|
||
|
|
|
||
|
|
thread::spawn(move || {
|
||
|
|
let vals = vec![
|
||
|
|
String::from("more"),
|
||
|
|
String::from("messages"),
|
||
|
|
String::from("for"),
|
||
|
|
String::from("you"),
|
||
|
|
];
|
||
|
|
|
||
|
|
for val in vals {
|
||
|
|
tx.send(val).unwrap();
|
||
|
|
thread::sleep(Duration::from_secs(1));
|
||
|
|
}
|
||
|
|
});
|
||
|
|
|
||
|
|
for received in rx {
|
||
|
|
println!("Got: {}", received);
|
||
|
|
}
|
||
|
|
|
||
|
|
// --snip--
|
||
|
|
// ANCHOR_END: here
|
||
|
|
}
|