95 lines
2.8 KiB
Rust
95 lines
2.8 KiB
Rust
// run-pass
|
|
#![allow(dead_code)]
|
|
#![allow(unused_assignments)]
|
|
#![allow(unused_variables)]
|
|
// ignore-emscripten no threads support
|
|
// needs-unwind
|
|
|
|
use std::thread;
|
|
use std::sync::mpsc::{channel, Sender};
|
|
|
|
#[derive(PartialEq, Debug)]
|
|
enum Message {
|
|
Dropped,
|
|
DestructorRan
|
|
}
|
|
|
|
struct SendOnDrop {
|
|
sender: Sender<Message>
|
|
}
|
|
|
|
impl Drop for SendOnDrop {
|
|
fn drop(&mut self) {
|
|
self.sender.send(Message::Dropped).unwrap();
|
|
}
|
|
}
|
|
|
|
enum Foo {
|
|
SimpleVariant(Sender<Message>),
|
|
NestedVariant(Box<usize>, SendOnDrop, Sender<Message>),
|
|
FailingVariant { on_drop: SendOnDrop }
|
|
}
|
|
|
|
impl Drop for Foo {
|
|
fn drop(&mut self) {
|
|
match self {
|
|
&mut Foo::SimpleVariant(ref mut sender) => {
|
|
sender.send(Message::DestructorRan).unwrap();
|
|
}
|
|
&mut Foo::NestedVariant(_, _, ref mut sender) => {
|
|
sender.send(Message::DestructorRan).unwrap();
|
|
}
|
|
&mut Foo::FailingVariant { .. } => {
|
|
panic!("Failed");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
pub fn main() {
|
|
let (sender, receiver) = channel();
|
|
{
|
|
let v = Foo::SimpleVariant(sender);
|
|
}
|
|
assert_eq!(receiver.recv().unwrap(), Message::DestructorRan);
|
|
assert_eq!(receiver.recv().ok(), None);
|
|
|
|
let (sender, receiver) = channel();
|
|
{
|
|
let v = Foo::NestedVariant(Box::new(42), SendOnDrop { sender: sender.clone() }, sender);
|
|
}
|
|
assert_eq!(receiver.recv().unwrap(), Message::DestructorRan);
|
|
assert_eq!(receiver.recv().unwrap(), Message::Dropped);
|
|
assert_eq!(receiver.recv().ok(), None);
|
|
|
|
let (sender, receiver) = channel();
|
|
let t = thread::spawn(move|| {
|
|
let v = Foo::FailingVariant { on_drop: SendOnDrop { sender: sender } };
|
|
});
|
|
assert_eq!(receiver.recv().unwrap(), Message::Dropped);
|
|
assert_eq!(receiver.recv().ok(), None);
|
|
drop(t.join());
|
|
|
|
let (sender, receiver) = channel();
|
|
let t = {
|
|
thread::spawn(move|| {
|
|
let mut v = Foo::NestedVariant(Box::new(42), SendOnDrop {
|
|
sender: sender.clone()
|
|
}, sender.clone());
|
|
v = Foo::NestedVariant(Box::new(42),
|
|
SendOnDrop { sender: sender.clone() },
|
|
sender.clone());
|
|
v = Foo::SimpleVariant(sender.clone());
|
|
v = Foo::FailingVariant { on_drop: SendOnDrop { sender: sender } };
|
|
})
|
|
};
|
|
assert_eq!(receiver.recv().unwrap(), Message::DestructorRan);
|
|
assert_eq!(receiver.recv().unwrap(), Message::Dropped);
|
|
assert_eq!(receiver.recv().unwrap(), Message::DestructorRan);
|
|
assert_eq!(receiver.recv().unwrap(), Message::Dropped);
|
|
assert_eq!(receiver.recv().unwrap(), Message::DestructorRan);
|
|
assert_eq!(receiver.recv().unwrap(), Message::Dropped);
|
|
assert_eq!(receiver.recv().ok(), None);
|
|
drop(t.join());
|
|
}
|