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

34 lines
685 B
Rust

// xfail-stage0
// xfail-stage1
// xfail-stage2
fn main() -> () {
test00();
}
fn test00_start(chan[int] c, int number_of_messages) {
let int i = 0;
while (i < number_of_messages) {
c <| i;
i += 1;
}
}
fn test00() {
let int r = 0;
let int sum = 0;
let port[int] p = port();
let int number_of_messages = 10;
let task t0 = spawn thread "child"
test00_start(chan(p), number_of_messages);
let int i = 0;
while (i < number_of_messages) {
p |> r; sum += r; log (r);
i += 1;
}
join t0;
assert (sum == (number_of_messages * (number_of_messages - 1)) / 2);
}