// run-pass | |
#![allow(unused_variables)] | |
// ignore-emscripten no threads support | |
use std::sync::mpsc::{channel, Sender}; | |
use std::thread; | |
fn start(tx: &Sender<isize>, start: isize, number_of_messages: isize) { | |
let mut i: isize = 0; | |
while i< number_of_messages { tx.send(start + i).unwrap(); i += 1; } | |
} | |
pub fn main() { | |
println!("Check that we don't deadlock."); | |
let (tx, rx) = channel(); | |
let _ = thread::spawn(move|| { start(&tx, 0, 10) }).join(); | |
println!("Joined task"); | |
} |