Struct DefaultTaskScheduler 

pub struct DefaultTaskScheduler { /* private fields */ }

Default task scheduler implementation

Provides a comprehensive scheduling implementation with configurable algorithms, priority handling, dependency resolution, and queue management.

Implementations

impl DefaultTaskScheduler

pub fn new(config: SchedulerConfig) -> Self

Create a new default task scheduler

Trait Implementations

impl TaskScheduler for DefaultTaskScheduler

fn schedule_task(&mut self, task: ExecutionTask) -> SklResult<TaskHandle>

Schedule a single task for execution

fn schedule_batch( &mut self, tasks: Vec<ExecutionTask>, ) -> SklResult<Vec<TaskHandle>>

Schedule multiple tasks as a batch

fn cancel_task(&mut self, handle: TaskHandle) -> SklResult<()>

Cancel a scheduled task

fn get_status(&self) -> SchedulerStatus

Get current scheduler status and metrics

fn update_config(&mut self, config: SchedulerConfig) -> SklResult<()>

Update scheduler configuration

async fn shutdown_gracefully(&mut self) -> SklResult<()>

Shutdown scheduler gracefully

fn get_next_task(&mut self) -> Option<(ExecutionTask, TaskHandle)>

Get next task to execute (for scheduler implementations)

fn mark_task_completed(&mut self, handle: &TaskHandle) -> SklResult<()>

Mark task as completed

fn mark_task_failed( &mut self, handle: &TaskHandle, _error: String, ) -> SklResult<()>

Mark task as failed