116 lines
2.5 KiB
Rust
116 lines
2.5 KiB
Rust
// -*- rust -*-
|
|
// xfail-pretty
|
|
|
|
/*
|
|
A parallel version of fibonacci numbers.
|
|
|
|
This version is meant mostly as a way of stressing and benchmarking
|
|
the task system. It supports a lot of command-line arguments to
|
|
control how it runs.
|
|
|
|
*/
|
|
|
|
use std;
|
|
|
|
import std::{time, getopts};
|
|
import io::writer_util;
|
|
import int::range;
|
|
import comm::port;
|
|
import comm::chan;
|
|
import comm::send;
|
|
import comm::recv;
|
|
|
|
import core::result;
|
|
import result::{ok, err};
|
|
|
|
fn fib(n: int) -> int {
|
|
fn pfib(c: chan<int>, n: int) {
|
|
if n == 0 {
|
|
send(c, 0);
|
|
} else if n <= 2 {
|
|
send(c, 1);
|
|
} else {
|
|
let p = port();
|
|
let ch = chan(p);
|
|
task::spawn {|| pfib(ch, n - 1); };
|
|
task::spawn {|| pfib(ch, n - 2); };
|
|
send(c, recv(p) + recv(p));
|
|
}
|
|
}
|
|
|
|
let p = port();
|
|
let ch = chan(p);
|
|
let t = task::spawn {|| pfib(ch, n); };
|
|
ret recv(p);
|
|
}
|
|
|
|
type config = {stress: bool};
|
|
|
|
fn parse_opts(argv: [str]) -> config {
|
|
let opts = [getopts::optflag("stress")];
|
|
|
|
let opt_args = vec::slice(argv, 1u, vec::len(argv));
|
|
|
|
|
|
alt getopts::getopts(opt_args, opts) {
|
|
ok(m) { ret {stress: getopts::opt_present(m, "stress")} }
|
|
err(_) { fail; }
|
|
}
|
|
}
|
|
|
|
fn stress_task(&&id: int) {
|
|
let mut i = 0;
|
|
loop {
|
|
let n = 15;
|
|
assert (fib(n) == fib(n));
|
|
i += 1;
|
|
#error("%d: Completed %d iterations", id, i);
|
|
}
|
|
}
|
|
|
|
fn stress(num_tasks: int) {
|
|
let mut results = [];
|
|
range(0, num_tasks) {|i|
|
|
let builder = task::builder();
|
|
results += [task::future_result(builder)];
|
|
task::run(builder) {|| stress_task(i); }
|
|
}
|
|
for results.each {|r| future::get(r); }
|
|
}
|
|
|
|
fn main(args: [str]) {
|
|
let args = if os::getenv("RUST_BENCH").is_some() {
|
|
["", "20"]
|
|
} else if args.len() <= 1u {
|
|
["", "8"]
|
|
} else {
|
|
args
|
|
};
|
|
|
|
let opts = parse_opts(args);
|
|
|
|
if opts.stress {
|
|
stress(2);
|
|
} else {
|
|
let max = option::get(uint::parse_buf(str::bytes(args[1]),
|
|
10u)) as int;
|
|
|
|
let num_trials = 10;
|
|
|
|
let out = io::stdout();
|
|
|
|
range(1, max + 1) {|n|
|
|
range(0, num_trials) {|i|
|
|
let start = time::precise_time_ns();
|
|
let fibn = fib(n);
|
|
let stop = time::precise_time_ns();
|
|
|
|
let elapsed = stop - start;
|
|
|
|
out.write_line(#fmt["%d\t%d\t%s", n, fibn,
|
|
u64::str(elapsed)]);
|
|
}
|
|
}
|
|
}
|
|
}
|