src/test/run-pass/task-comm-2.rs


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

// xfail-win32
use std;

import task;

fn main() {
    #debug("===== SPAWNING and JOINING THREAD TASKS =====");
    test00();
}

fn start(&&task_number: int) {
    #debug("Started task.");
    let i: int = 0;
    while i < 10000 { i = i + 1; }
    #debug("Finished task.");
}

fn test00() {
    let number_of_tasks: int = 8;

    let i: int = 0;
    let tasks = [];
    while i < number_of_tasks {
        i = i + 1;
        tasks += [task::spawn_joinable {|| start(i); }];
    }

    for t in tasks { task::join(t); }

    #debug("Joined all task.");
}