taskorch 0.1.0

Concurrent Pool for task processing
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


static PROCESS_START_TIME: std::sync::OnceLock<std::time::Instant> = std::sync::OnceLock::new();

#[macro_export]
macro_rules! w {
    () => {
        ::std::thread::sleep(std::time::Duration::from_millis(1));
    };
    ($t:expr) => {
        ::std::thread::sleep(std::time::Duration::from_millis($t));
    };
}

#[macro_export]
macro_rules! ti {
    () => {{
        let (s,m) = uptime();
        format!("[{s}.{m:03} {:?}]",::std::thread::current().id())
    }};
    ($s:expr) => {{
        let (s,m) = uptime();
        format!("[{s}.{m:03} {:?} {:?}]",::std::thread::current().id(),$s)
    }};
}


pub fn uptime()->(u64,u32) {
    let start = PROCESS_START_TIME.get_or_init(::std::time::Instant::now);
    let e = start.elapsed();
    let a = e.as_secs();
    let b = e.subsec_millis();
    (a,b)
}