delay_timer 0.11.6

Time-manager of delayed tasks. Like crontab, but synchronous asynchronous tasks are possible, and dynamic add/cancel/remove is supported.
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

#![allow(deprecated)]
use delay_timer::prelude::*;
use std::thread::sleep;
use std::time::Duration;

#[derive(Default)]
struct RequstBody {
    _id: u64,
    cron_expression: String,
    _token: String,
}

impl RequstBody {
    fn fake_request_body() -> Self {
        let string_buf = [16u16, 16u16, 16u16].repeat(10000);
        let cron_expression = String::from_utf16(&string_buf).unwrap_or_default();
        Self {
            cron_expression,
            ..Default::default()
        }
    }
}

impl From<RequstBody> for CandyCronStr {
    fn from(val: RequstBody) -> Self {
        CandyCronStr(val.cron_expression)
    }
}

// LD_PRELOAD=../../tools-bin/libmemory_profiler.so ./target/debug/examples/profile_memory
// ../../tools-bin/memory-profiler-cli server memory-profiling_*.dat
fn main() {
    let capacity: usize = 25_600;
    let mut task_builder_vec: Vec<TaskBuilder> = Vec::with_capacity(capacity);

    for _ in 0..capacity {
        task_builder_vec.push({
            let mut task_builder = TaskBuilder::default();
            task_builder
                .set_frequency_by_candy(CandyFrequency::Repeated(RequstBody::fake_request_body()));

            task_builder
        });
    }

    sleep(Duration::from_secs(25));

    for _ in 0..capacity {
        if let Some(mut task_builder) = task_builder_vec.pop() {
            task_builder.free();
        }
    }

    drop(task_builder_vec);

    dbg!("after drop");
}