Struct TaskRegistry 

pub struct TaskRegistry { /* private fields */ }

Central scheduler and store for all IDE tasks.

Implementations

impl TaskRegistry

pub fn new() -> Self

pub fn schedule_task( &mut self, key: TaskKey, trigger: TaskTrigger, command: String, ) -> TaskId

Schedule a new task on key.queue.

Any existing running or queued task with the same TaskKey is cancelled first (Rule 2 / Rule 4). If no task is currently running on the queue the new task starts immediately (status → Running); otherwise it is appended to the FIFO queue (status → Pending).

Returns the TaskId of the newly created task.

pub fn cancel(&mut self, task_id: TaskId) -> Option<TaskId>

Cancel the task identified by task_id.

• If the task is Running its CancellationToken is triggered and status is set to TaskStatus::Cancelled. The running slot is cleared and start_next is called for the queue.
• If the task is Pending it is removed from the queue and its status is set to TaskStatus::Cancelled.
• If the task is already finished or cancelled this is a no-op.

Returns the TaskId of the next task that was started as a side-effect of releasing the running slot (only possible when cancelling a Running task that had a non-empty pending queue).

pub fn cancel_by_key(&mut self, key: &TaskKey) -> Option<TaskId>

Cancel all running and queued tasks whose TaskKey equals key.

Returns the TaskId of any task that started as a side-effect of releasing a running slot.

pub fn mark_running(&mut self, task_id: TaskId)

Transition a task from Pending to Running and record started_at.

Also registers the task in the running map for its queue. Panics in debug builds if the task is not in Pending state.

pub fn mark_finished( &mut self, task_id: TaskId, status: TaskStatus, ) -> Option<TaskId>

Record a terminal status for a finished task and start the next one.

If the task was already Cancelled the status is not overwritten — a cancelled task stays cancelled regardless of the final process outcome.

Returns the TaskId of the next task that was started as a side-effect, if the queue had a pending task waiting.

pub fn all_tasks(&self) -> impl Iterator<Item = &Task>

Returns an iterator over all tasks ever created (in arbitrary order).

pub fn task_count(&self) -> usize

Returns the total number of tasks ever created (running, pending, or finished).

pub fn get(&self, id: TaskId) -> Option<&Task>

Returns a reference to a task by ID, or None if it does not exist.

pub fn running_task(&self, queue: &TaskQueueId) -> Option<TaskId>

Returns the TaskId of the currently running task on queue, if any.

pub fn running_tasks(&self) -> impl Iterator<Item = (&TaskQueueId, &TaskId)>

Returns an iterator over all currently running tasks (queue_id, task_id).

pub fn recently_finished_tasks(&self) -> impl Iterator<Item = TaskId> + '_

Returns an iterator over recently finished task IDs (newest last, max 5).

Only tasks with a terminal status (Success / Warning / Error / Cancelled) are included. The caller can use TaskRegistry::get to read the full task record.

pub fn pending_tasks(&self, queue: &TaskQueueId) -> &[TaskId]

Returns the ordered pending task IDs for queue (front = next to run).

Trait Implementations

impl Default for TaskRegistry

fn default() -> Self

Returns the “default value” for a type.