Struct TaskScheduler 

pub struct TaskScheduler { /* private fields */ }

Task scheduler for managing task execution order.

Implementations

impl TaskScheduler

pub fn new() -> Self

Create a new task scheduler.

pub fn add_task(&mut self, task: Task)

Add a task to the scheduler.

pub fn next_task(&mut self) -> Option<Task>

Get the next pending task.

pub fn mark_running(&mut self, task: Task, worker_id: String)

Mark a task as running.

pub fn mark_completed(&mut self, task_id: TaskId) -> Result<()>

Mark a task as completed.

pub fn mark_failed(&mut self, task_id: TaskId) -> Result<()>

Mark a task as failed and potentially retry.

pub fn pending_count(&self) -> usize

Get the number of pending tasks.

pub fn running_count(&self) -> usize

Get the number of running tasks.

pub fn completed_count(&self) -> usize

Get the number of completed tasks.

pub fn failed_count(&self) -> usize

Get the number of failed tasks.

pub fn is_complete(&self) -> bool

Check if all tasks are complete.

Trait Implementations

impl Debug for TaskScheduler

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

Formats the value using the given formatter.

impl Default for TaskScheduler

fn default() -> Self

Returns the “default value” for a type.