eater/async-std
1
0
Fork 0
forked from mirror/async-std
Code Issues Pull requests Releases Wiki Activity

Name threads after what they do

Browse source
This commit is contained in:
Florian Gilcher 2019-08-15 10:29:55 +02:00
parent f38923d0cc
commit a9b970c8ec
No known key found for this signature in database
GPG key ID: E7B51D33F8EBF61B
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
examples/integrate-thread.rs
View file

@ -44,28 +44,28 @@ where
} }
fn main() { fn main() {
let thread_handle = spawn(move || { let sleepy_thread = spawn(move || {
thread::sleep(time::Duration::from_millis(1000)); thread::sleep(time::Duration::from_millis(1000));
String::from("Finished") String::from("Finished")
}); });
task::block_on(async move { task::block_on(async move {
println!("waiting for thread 1"); println!("waiting for sleepy thread");
let thread_result = thread_handle.join().await; let thread_result = sleepy_thread.join().await;
match thread_result { match thread_result {
Ok(s) => println!("Result: {}", s), Ok(s) => println!("Result: {}", s),
Err(e) => println!("Error: {:?}", e), Err(e) => println!("Error: {:?}", e),
} }
}); });
let thread_handle = spawn(move || { let panicing_thread = spawn(move || {
panic!("aaah!"); panic!("aaah!");
String::from("Finished!") String::from("Finished!")
}); });
task::block_on(async move { task::block_on(async move {
println!("waiting for thread 2"); println!("waiting for panicing thread");
let thread_result = thread_handle.join().await; let thread_result = panicing_thread.join().await;
match thread_result { match thread_result {
Ok(s) => println!("Result: {}", s), Ok(s) => println!("Result: {}", s),
Err(e) => println!("Error: {:?}", e), Err(e) => println!("Error: {:?}", e),