2018-08-30 12:18:55 +00:00
|
|
|
// run-pass
|
2018-09-25 21:51:35 +00:00
|
|
|
#![allow(unused_must_use)]
|
2016-02-11 11:34:41 +00:00
|
|
|
// ignore-emscripten no threads support
|
2015-03-22 20:13:15 +00:00
|
|
|
// pretty-expanded FIXME #23616
|
|
|
|
|
2014-12-23 19:53:35 +00:00
|
|
|
use std::sync::mpsc::{channel, Sender};
|
2015-03-30 18:00:05 +00:00
|
|
|
use std::thread;
|
2013-05-25 02:35:29 +00:00
|
|
|
|
2015-03-26 00:06:52 +00:00
|
|
|
fn start(tx: &Sender<isize>, i0: isize) {
|
2012-03-22 15:39:41 +00:00
|
|
|
let mut i = i0;
|
2012-01-05 05:14:53 +00:00
|
|
|
while i > 0 {
|
2015-01-02 07:53:35 +00:00
|
|
|
tx.send(0).unwrap();
|
2012-01-05 05:14:53 +00:00
|
|
|
i = i - 1;
|
|
|
|
}
|
2010-08-25 04:06:56 +00:00
|
|
|
}
|
|
|
|
|
2013-02-02 03:43:17 +00:00
|
|
|
pub fn main() {
|
2015-05-08 15:12:29 +00:00
|
|
|
// Spawn a thread that sends us back messages. The parent thread
|
2010-09-08 01:01:35 +00:00
|
|
|
// is likely to terminate before the child completes, so from
|
|
|
|
// the child's point of view the receiver may die. We should
|
|
|
|
// drop messages on the floor in this case, and not crash!
|
2014-03-09 21:58:32 +00:00
|
|
|
let (tx, rx) = channel();
|
2015-04-13 22:15:32 +00:00
|
|
|
let t = thread::spawn(move|| {
|
2014-03-09 21:58:32 +00:00
|
|
|
start(&tx, 10)
|
2013-12-06 02:19:06 +00:00
|
|
|
});
|
2014-03-09 21:58:32 +00:00
|
|
|
rx.recv();
|
2015-04-13 22:15:32 +00:00
|
|
|
t.join();
|
2011-08-10 16:27:22 +00:00
|
|
|
}
|