libp2prs-runtime 0.3.0

runtime which support async-std and tokio
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

use libp2prs_runtime::task;
use std::time::Duration;

fn main() {
    task::block_on(async {
        //let s = TcpStream::connect();

        let h = task::spawn(async {
            {
                task::sleep(Duration::from_secs(1)).await;
            }

            32
        });

        let a = h.wait().await;
        println!("forced closed {:?}", a);

        task::sleep(Duration::from_millis(1200)).await;

        println!("wait for exit ");

        // let a = h.terminate().await;
        // println!("forced closed {:?}", a);

        //h.await;

        //let b = h.cancel().await;
        std::thread::sleep(Duration::from_millis(1000));

        println!("exited");
    });

    std::thread::sleep(Duration::from_millis(1000));
}