rustque 1.1.1

this is a fast on disk perstant memeory mapped que for rust it stores Vec<u8> to a file on a disk.
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
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74


mod io;
mod config;
mod que;
mod map;
mod disk;
mod workers;

pub use config::Config;
pub use que::Que;
// use tokio;

use std::time::Instant;

#[tokio::main]
async fn main() {

    let hold = Instant::now();

    if false {
        io::read_full(
            "D://workstation/expo/rust/rust_store/test/rustque/que1.rustque".to_string()
        ).await;
    }

    let mut que:Que;
    match Que::new(Config::new(
        "D://workstation/expo/rust/rust_store/test/rustque/que1.rustque".to_string(),
        10000,
        10
    )).await{
        Ok(v)=>{
            // println!("que made successfully");
            que = v;
        },
        Err(e)=>{
            println!("!!! failed-que::new => {:?}",e);
            return;
        }
    }

    println!("que initiated : {:?}",hold.elapsed());

    if false{que.print_map().await;}

    for i in 0..25{
        let write_hold = Instant::now();
        for i in 0..1000{
            match que.add(vec![1,2,3]).await{
                Ok(_)=>{
                    // println!(">>> success-que-add {:?}",i);
                },
                Err(_)=>{
                    println!("!!! failed-que-add");
                }
            }
        }
        println!("write complete : {:?}",write_hold.elapsed());
    }

    println!("final in : {:?}",hold.elapsed());

    if false{que.print_map().await;}

    if false {
        io::read_full(
            "D://workstation/expo/rust/rust_store/test/rustque/que1.rustque".to_string()
        ).await;
    }

}

//que(message)(await confirm)->map(message)->disk(message)(submit confirm)