Struct TaskPool 

pub struct TaskPool<K, T>
where
    T: Send + 'static,
{ /* private fields */ }

A keyed pool of async tasks with lifecycle status tracking.

Each key maps to at most one running task. Spawning under an existing key aborts the previous task. Status transitions (Pending, Resolved, Error, Aborted) are reported via the on_status_change callback provided at construction time.

Type parameters

• K: Key type (must be Hash + Eq + Clone).
• T: Task output type.

Implementations

impl<K, T> TaskPool<K, T>

where K: Hash + Eq + Clone + Send + 'static, T: Send + 'static,

pub fn new( rt: Handle, on_status_change: impl Fn(&K, TaskStatus<T>) + Send + Sync + 'static, ) -> Self

Create a new task pool.

on_status_change is called whenever a task’s status transitions (Pending, Resolved, Error, Aborted). The caller provides a closure that updates state (e.g., a HashMap in their DomainData).

pub fn spawn<F, Fut>(&self, key: K, f: F)

where F: FnOnce() -> Fut + Send + 'static, Fut: Future<Output = T> + Send + 'static,

Spawn a task under the given key.

Aborts any previous task with the same key. Sets status to Pending, then Resolved on completion. If the task panics, the status remains Pending (the panic is caught by tokio but the callback is not reached).

pub fn abort(&self, key: &K) -> bool

Abort the task under the given key.

Returns true if a task was found and aborted. Sets status to Aborted via on_status_change.

pub async fn shutdown(&self, timeout: Duration)

Gracefully shut down all tasks.

Awaits each JoinHandle with a deadline; force-aborts tasks that don’t finish within timeout.

Trait Implementations

impl<K: Clone, T> Clone for TaskPool<K, T>

where T: Send + 'static + Clone,

fn clone(&self) -> TaskPool<K, T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<K, T> Debug for TaskPool<K, T>

where T: Send + 'static,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.