Struct LockFreeTaskScheduler 

pub struct LockFreeTaskScheduler { /* private fields */ }

Lock-free task scheduler with work-stealing queues

Implementations

impl LockFreeTaskScheduler

pub fn new(num_workers: usize, local_queue_capacity: usize) -> Self

Create a new lock-free task scheduler

pub fn submit_task<F>( &self, config: TaskConfig, task: F, ) -> Result<Receiver<TaskResult<()>>>

where F: FnOnce() -> BoxFuture<'static, Result<()>> + Send + 'static,

Submit a task for execution

pub fn submit_batch<F>( &self, tasks: Vec<(TaskConfig, F)>, ) -> Result<Vec<Receiver<TaskResult<()>>>>

where F: FnOnce() -> BoxFuture<'static, Result<()>> + Send + 'static,

Submit multiple tasks in batch

pub fn steal_task(&self, worker_id: usize) -> Option<ScheduledTask>

Try to steal a task from queues (used by workers)

pub fn mark_task_completed( &self, worker_id: usize, _task_id: &str, duration: Duration, )

Mark a task as completed

pub fn mark_task_failed(&self, worker_id: usize, _task_id: &str)

Mark a task as failed

pub fn get_stats(&self) -> SchedulerStats

Get current scheduler statistics

pub fn get_worker_state(&self, worker_id: usize) -> Option<WorkerState>

Get worker state

pub fn get_all_worker_states(&self) -> Vec<(usize, WorkerState)>

Get all worker states

pub fn has_pending_tasks(&self) -> bool

Check if scheduler has pending tasks

pub fn pending_task_count(&self) -> usize

Get the number of pending tasks

pub fn reset_stats(&self)

Reset all statistics

pub async fn shutdown(&self, timeout: Duration) -> Result<()>

Shutdown the scheduler gracefully

pub fn get_queue_lengths(&self) -> Vec<usize>

Get queue lengths for monitoring

pub fn get_load_balance_metrics(&self) -> LoadBalanceMetrics

Get load balancing metrics

pub fn get_local_queue_capacity(&self) -> usize

Get the local queue capacity