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");
}