mco 0.1.48

Rust Coroutine Library like go
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
36
37

use mco::coroutine::sleep;
use mco::{chan, co};
use std::time::Duration;

fn main() {
    //unbounded
    let (s, r) = chan!();
    s.send(1);
    println!(
        "remain msg:{},sender num:{},receiver num:{}",
        r.remain(),
        r.sender_num(),
        r.receiver_num()
    );
    let rv = r.recv().unwrap();
    println!("recv = {},remain:{}", rv, r.remain());

    sleep(Duration::from_secs(1));

    //bounded length, If the sender sends more messages than the limit, it waits until the message is consumed
    let (s, r) = chan!(1);
    co!(move || {
        let send_result = s.send(1);
        println!("send 1 is_ok:{}", send_result.is_ok());
        //will blocking until the excess messages are consumed or the channel is closed
        println!("s.send(2) blocking 2s...");
        let send_result = s.send(2);
        println!("send 2 is_ok: {:?}", send_result);
    });

    sleep(Duration::from_secs(2));
    let rv = r.recv().unwrap();
    println!("recv = {},remain:{}", rv, r.remain());
    let rv = r.recv().unwrap();
    println!("recv = {},remain:{}", rv, r.remain());
    sleep(Duration::from_secs(1));
}