68 lines
1.4 KiB
Rust
68 lines
1.4 KiB
Rust
// Test for concurrent tasks
|
|
|
|
enum msg {
|
|
ready(comm::chan<msg>),
|
|
start,
|
|
done(int),
|
|
}
|
|
|
|
fn calc(children: uint, parent_ch: comm::chan<msg>) {
|
|
let port = comm::port();
|
|
let chan = comm::chan(port);
|
|
let mut child_chs = [];
|
|
let mut sum = 0;
|
|
|
|
iter::repeat (children) {||
|
|
task::spawn {||
|
|
calc(0u, chan);
|
|
};
|
|
}
|
|
|
|
iter::repeat (children) {||
|
|
alt check comm::recv(port) {
|
|
ready(child_ch) {
|
|
child_chs += [child_ch];
|
|
}
|
|
}
|
|
}
|
|
|
|
comm::send(parent_ch, ready(chan));
|
|
|
|
alt check comm::recv(port) {
|
|
start {
|
|
vec::iter (child_chs) { |child_ch|
|
|
comm::send(child_ch, start);
|
|
}
|
|
}
|
|
}
|
|
|
|
iter::repeat (children) {||
|
|
alt check comm::recv(port) {
|
|
done(child_sum) { sum += child_sum; }
|
|
}
|
|
}
|
|
|
|
comm::send(parent_ch, done(sum + 1));
|
|
}
|
|
|
|
fn main(args: [str]) {
|
|
let children = if vec::len(args) == 2u {
|
|
option::get(uint::from_str(args[1]))
|
|
} else {
|
|
100u
|
|
};
|
|
let port = comm::port();
|
|
let chan = comm::chan(port);
|
|
task::spawn {||
|
|
calc(children, chan);
|
|
};
|
|
alt check comm::recv(port) {
|
|
ready(chan) {
|
|
comm::send(chan, start);
|
|
}
|
|
}
|
|
let sum = alt check comm::recv(port) {
|
|
done(sum) { sum }
|
|
};
|
|
#error("How many tasks? %d tasks.", sum);
|
|
} |