Struct TaskScheduler 

pub struct TaskScheduler { /* private fields */ }

Task scheduler

Implementations

impl TaskScheduler

pub fn new() -> Self

Create new task scheduler

pub fn submit_task(&mut self, task: Task) -> Result<(), AmbientError>

Submit task

pub fn get_pending_tasks(&self) -> Vec<Task>

Get pending tasks

pub fn get_pending_tasks_into( &self, out: &mut [TaskHandle], ) -> Result<usize, AmbientError>

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

Dispatch the next pending task to a device, moving it to running. Returns the dispatched task, or None if no tasks are pending.

pub fn complete_task( &mut self, task_id: &str, device_id: &str, success: bool, usage: ResourceUsage, )

Mark a running task as completed, recording it in execution history.

pub fn running_count(&self) -> usize

Get the number of currently running tasks.

pub fn completed_count(&self) -> usize

Get the number of completed tasks.

pub fn recent_history(&self, n: usize) -> &[TaskExecutionRecord]

Get recent execution history records.

pub fn set_policy(&mut self, policy: SchedulingPolicy)

Set the scheduling policy.