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

// xfail-win32
use std;

import task;

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

fn start(&&task_number: int) {
    log "Started task.";
    let i: int = 0;
    while i < 10000 { i = i + 1; }
    log "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(copy i, start)];
    }

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

    log "Joined all task.";
}