This is a simple task queue implemented in Rust. It allows you to create tasks that can either expire after a specified duration or run indefinitely. The application uses channels for communication between threads and handles task execution in a separate thread.
The Task struct represents a task that can be executed. It includes the following methods:
new: Creates a new task that expires after a specified duration.new_dont_expire: Creates a new task that does not expire.has_expired: Checks if the task has expired.run: Executes the task.
-> Executing task without expiration...
-> Starting task with a 1-second expiration. Sleeping for 2 seconds...
-> Completed task after sleep.
-> Executing another task without expiration...
-> Executing task from another thread...
-> Task will panic in 5 seconds!
thread '<unnamed>' panicked at src/main.rs:49:13
This project is based on the concept of the Dispatcher Thread from The Forgotten Server, replacing the use of mutex with an Multi-producer, single-consumer (lock-free) channel in Rust to optimize message exchange between threads.