// Send/Receive lots of messages.
for j in range(0u, count) {
//println!("task %?, iter %?", i, j);
- let num_chan2 = num_chan.take_unwrap();
- let num_port2 = num_port.take_unwrap();
+ let num_chan2 = num_chan.take().unwrap();
+ let num_port2 = num_port.take().unwrap();
send(&num_chan2, i * j);
num_chan = Some(num_chan2);
let _n = recv(&num_port2);
} else if args.len() <= 1u {
vec!("".to_string(), "10".to_string(), "100".to_string())
} else {
- args.clone().move_iter().collect()
+ args.clone().into_iter().collect()
};
let num_tasks = from_str::<uint>(args.get(1).as_slice()).unwrap();
thread_ring(0, msg_per_task, num_chan, num_port);
// synchronize
- for f in futures.mut_iter() {
+ for f in futures.iter_mut() {
let _ = f.get();
}