Struct TaskRegistry 

pub struct TaskRegistry { /* private fields */ }

Public task registry facade used by executor lifecycle tracking and tests.

Implementations

impl TaskRegistry

pub fn new() -> Self

Create a new task registry.

pub fn register_task(&mut self) -> u64

Register a new task and return its ID.

pub fn mark_started(&self, task_id: u64, worker_id: usize)

Mark a task as started.

pub fn mark_completed(&self, task_id: u64)

Mark a task as completed.

pub fn is_completed(&self, task_id: u64) -> bool

Check if a task is completed.

pub fn get_metadata(&self, task_id: u64) -> Option<TaskMetadata>

Get task metadata.

pub fn cleanup_completed(&mut self, older_than: Duration)

Remove old completed tasks to prevent retained task metadata growth.

pub fn active_count(&self) -> usize

Get count of active tasks.

pub fn completed_count(&self) -> usize

Get count of completed tasks.

pub fn register_waker(&self, task_id: u64, waker: &Waker) -> bool

Register a waker to be notified when the task completes.

Trait Implementations

impl Debug for TaskRegistry

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

Formats the value using the given formatter.

impl Default for TaskRegistry

fn default() -> Self

Returns the “default value” for a type.