chan 0.1.23

DEPRECATED. Use crossbeam-channel instead.
Documentation 
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
32
33
34
35

#[macro_use]
extern crate chan;

use std::thread;

use chan::{Receiver, Sender};

fn fibonacci(c: Sender<u64>, quit: Receiver<()>) {
    let (mut x, mut y) = (0, 1);
    loop {
        chan_select! {
            c.send(x) => {
                let oldx = x;
                x = y;
                y = oldx + y;
            },
            quit.recv() => {
                println!("quit");
                return;
            }
        }
    }
}

fn main() {
    let (csend, crecv) = chan::sync(0);
    let (qsend, qrecv) = chan::sync(0);
    thread::spawn(move || {
        for _ in 0..10 {
            println!("{}", crecv.recv().unwrap());
        }
        qsend.send(());
    });
    fibonacci(csend, qrecv);
}