rust/src/test/run-pass/task-comm-9.rs

31 lines
657 B
Rust
Raw Normal View History

impure fn main() -> () {
2010-07-28 18:58:17 -05:00
test00();
}
impure fn test00_start(chan[int] c, int number_of_messages) {
2010-07-28 18:58:17 -05:00
let int i = 0;
while (i < number_of_messages) {
c <| i;
i += 1;
}
}
impure fn test00() {
2010-07-28 18:58:17 -05:00
let int r = 0;
let int sum = 0;
let port[int] p = port();
let int number_of_messages = 10;
2010-09-08 01:37:51 -05:00
let task t0 = spawn thread "child"
test00_start(chan(p), number_of_messages);
2010-07-28 18:58:17 -05:00
let int i = 0;
while (i < number_of_messages) {
r <- p; sum += r; log (r);
i += 1;
}
join t0;
check (sum == (number_of_messages * (number_of_messages - 1)) / 2);
}