3 stable releases

1.0.2 Mar 26, 2024
1.0.1 May 19, 2023

#728 in Concurrency

Download history 193/week @ 2024-10-24 161/week @ 2024-10-31 301/week @ 2024-11-07 359/week @ 2024-11-14 175/week @ 2024-11-21 116/week @ 2024-11-28 137/week @ 2024-12-05 334/week @ 2024-12-12 480/week @ 2024-12-19 116/week @ 2024-12-26 389/week @ 2025-01-02 288/week @ 2025-01-09 174/week @ 2025-01-16 413/week @ 2025-01-23 456/week @ 2025-01-30 523/week @ 2025-02-06

1,580 downloads per month
Used in 3 crates

MIT license

26KB
502 lines

timedmap Crates.io docs.rs

A more or less port of my package timedmap - originally written in Go - but for Rust!

timedmap provides a thread-safe hash map with expiring key-value pairs and automatic cleanup mechnaisms for popular async runtimes.

Basic Example

use timedmap::TimedMap;
use std::time::Duration;

let tm = TimedMap::new();
tm.insert("foo", 1, Duration::from_millis(100));
tm.insert("bar", 2, Duration::from_millis(200));
tm.insert("baz", 3, Duration::from_millis(300));
assert_eq!(tm.get(&"foo"), Some(1));
assert_eq!(tm.get(&"bar"), Some(2));
assert_eq!(tm.get(&"baz"), Some(3));

std::thread::sleep(Duration::from_millis(120));
assert_eq!(tm.get(&"foo"), None);
assert_eq!(tm.get(&"bar"), Some(2));
assert_eq!(tm.get(&"baz"), Some(3));

std::thread::sleep(Duration::from_millis(100));
assert_eq!(tm.get(&"foo"), None);
assert_eq!(tm.get(&"bar"), None);
assert_eq!(tm.get(&"baz"), Some(3));

Cleanup Example

You can use the start_cleaner function to automatically clean up expired key-value pairs in given time intervals using popular async runtimes.

Currently, only implementations for tokio and actix-rt are available. Implentations for other popular runtimes are planned in the future. If you want to contribute an implementation, feel free to create a pull request. 😄

use timedmap::{TimedMap, start_cleaner};
use std::time::Duration;
use std::sync::Arc;

let tm = Arc::new(TimedMap::new());
tm.insert("foo", 1, Duration::from_secs(60));

let cancel = start_cleaner(tm, Duration::from_secs(10));

cancel();

Dependencies

~0–9.5MB
~65K SLoC