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

use mco::co;
use mco::coroutine::sleep;
use mco::std::errors::Error;
use mco::std::pool::{Pool, Task};
use std::sync::Arc;
use std::time::Duration;

fn main() {
    let pool = Arc::new(Pool::new(10));
    let copy = pool.clone();
    co!(move || {
        copy.run();
    });
    for n in 0..100 {
        pool.put(Task::new(move || -> Result<(), Error> {
            sleep(Duration::from_secs(1));
            println!("num:{}", n);
            Ok(())
        }));
    }
    sleep(Duration::from_secs(20));
    //pool.close(); //control pool close
    sleep(Duration::from_secs(5));
    println!("done");
}