minitimer 0.1.7

A mini timer of delayed tasks. Only asynchronous tasks are possible on tokio runtime, 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

//! Integration tests for task failure handling.
//!
//! These tests verify that failing tasks don't crash the timer
//! and are handled gracefully.

use std::sync::Arc;
use std::sync::atomic::{AtomicU64, Ordering};
use std::time::Duration;

use minitimer::MiniTimer;
use minitimer::task::TaskBuilder;

mod common;
use common::FailingTask;

/// Test that failing tasks don't crash the timer.
#[tokio::test]
async fn test_failing_task_does_not_crash_timer() {
    let counter = Arc::new(AtomicU64::new(0));

    let timer = MiniTimer::new();

    let task = TaskBuilder::new(1)
        .with_frequency_repeated_by_seconds(1)
        .spawn_async(FailingTask::new(counter.clone()))
        .unwrap();

    timer.add_task(task).unwrap();

    // Wait for task to execute (and fail) multiple times
    tokio::time::sleep(Duration::from_secs(4)).await;

    // Verify timer is still running
    assert!(
        timer.is_running(),
        "Timer should still be running after task failures"
    );

    // Verify task was executed (even though it failed)
    let count = counter.load(Ordering::SeqCst);
    assert!(
        count >= 1,
        "Failing task should still be executed, executed {} times",
        count
    );
}