Struct TaskScheduler

pub struct TaskScheduler { /* private fields */ }

Scheduler to manage and execute tasks in parallel

Implementations

impl TaskScheduler

pub fn new_with_config(app_config: &Config) -> Result<Self>

Create a new scheduler based on configuration

pub fn new_with_defaults() -> Self

Create a new scheduler with default settings (for testing)

pub fn new() -> Result<Self>

Create a new scheduler with default configuration

pub async fn submit_task( &self, task: Box<dyn Task + Send + Sync>, ) -> Result<TaskResult>

Submit a task with normal priority

pub async fn submit_task_with_priority( &self, task: Box<dyn Task + Send + Sync>, priority: TaskPriority, ) -> Result<TaskResult>

Submit a task with specified priority

pub async fn submit_batch_tasks( &self, tasks: Vec<Box<dyn Task + Send + Sync>>, ) -> Vec<TaskResult>

Submit multiple tasks and await all results

pub fn get_queue_size(&self) -> usize

Get number of tasks waiting in queue

pub fn get_active_workers(&self) -> usize

Get number of active workers

pub fn get_task_status(&self, task_id: &str) -> Option<TaskInfo>

Get status of a specific task

pub fn list_active_tasks(&self) -> Vec<TaskInfo>

List all active tasks

Trait Implementations

impl Clone for TaskScheduler

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.