2 #![allow(unused_must_use)]
3 // ignore-emscripten no threads support
6 use std
::sync
::mpsc
::{channel, Sender}
;
8 pub fn main() { test00(); }
10 fn test00_start(c
: &Sender
<isize>, number_of_messages
: isize) {
12 while i
< number_of_messages { c.send(i + 0).unwrap(); i += 1; }
17 let mut sum
: isize = 0;
18 let (tx
, rx
) = channel();
19 let number_of_messages
: isize = 10;
21 let result
= thread
::spawn(move|| {
22 test00_start(&tx
, number_of_messages
);
26 while i
< number_of_messages
{
27 sum
+= rx
.recv().unwrap();
34 assert_eq
!(sum
, number_of_messages
* (number_of_messages
- 1) / 2);