src/test/run-pass/preempt.rs


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

// xfail-test
// This checks that preemption works.

fn starve_main(alive: chan<int>) {
    #debug("signalling main");
    alive <| 1;
    #debug("starving main");
    let i: int = 0;
    loop { i += 1; }
}

fn main() {
    let alive: port<int> = port();
    #debug("main started");
    let s: task = spawn starve_main(chan(alive));
    let i: int;
    #debug("main waiting for alive signal");
    alive |> i;
    #debug("main got alive signal");
    while i < 50 { #debug("main iterated"); i += 1; }
    #debug("main completed");
}