rust/tests/pass/concurrency/simple.rs
2022-06-20 15:39:46 -07:00

78 lines
1.6 KiB
Rust

// ignore-windows: Concurrency on Windows is not supported yet.
// compile-flags: -Zmiri-strict-provenance
use std::thread;
fn create_and_detach() {
thread::spawn(|| ());
}
fn create_and_join() {
thread::spawn(|| ()).join().unwrap();
}
fn create_and_get_result() {
let nine = thread::spawn(|| 5 + 4).join().unwrap();
assert_eq!(nine, 9);
}
fn create_and_leak_result() {
thread::spawn(|| 7);
}
fn create_nested_and_detach() {
thread::spawn(|| {
thread::spawn(|| ());
});
}
fn create_nested_and_join() {
let handle = thread::spawn(|| thread::spawn(|| ()));
let handle_nested = handle.join().unwrap();
handle_nested.join().unwrap();
}
fn create_move_in() {
let x = String::from("Hello!");
thread::spawn(move || {
assert_eq!(x.len(), 6);
})
.join()
.unwrap();
}
fn create_move_out() {
let result = thread::spawn(|| String::from("Hello!")).join().unwrap();
assert_eq!(result.len(), 6);
}
fn panic() {
let result = thread::spawn(|| panic!("Hello!")).join().unwrap_err();
let msg = result.downcast_ref::<&'static str>().unwrap();
assert_eq!(*msg, "Hello!");
}
fn panic_named() {
thread::Builder::new()
.name("childthread".to_string())
.spawn(move || {
panic!("Hello, world!");
})
.unwrap()
.join()
.unwrap_err();
}
fn main() {
create_and_detach();
create_and_join();
create_and_get_result();
create_and_leak_result();
create_nested_and_detach();
create_nested_and_join();
create_move_in();
create_move_out();
panic();
panic_named();
}