timely 0.2.0

A low-latency data-parallel dataflow system in Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

extern crate timely;

use timely::dataflow::operators::*;

fn main() {

    let iterations = std::env::args().nth(1).unwrap().parse::<u64>().unwrap();

    // initializes and runs a timely dataflow
    timely::execute_from_args(std::env::args().skip(2), move |worker| {
        let index = worker.index();
        worker.dataflow(move |scope| {
            let (helper, cycle) = scope.loop_variable(iterations, 1);
            (0..1).take(if index == 0 { 1 } else { 0 })
                  .to_stream(scope)
                  .concat(&cycle)
                  .exchange(|&x| x)
                  .map_in_place(|x| *x += 1)
                  .connect_loop(helper);
        });
    }).unwrap();
}