Struct TaskScheduler

pub struct TaskScheduler { /* private fields */ }

任务调度器

Implementations

impl TaskScheduler

pub fn new(config: ParallelConfig) -> Self

创建新的任务调度器

pub fn add_task(&self, lazy_expr: Arc<LazyExpression>) -> usize

添加任务

pub fn get_next_task(&self) -> Option<ComputeTask>

获取下一个可执行的任务

pub fn complete_task( &self, task_id: usize, result: Result<Expression, ComputeError>, )

标记任务完成

pub fn get_task_result( &self, task_id: usize, ) -> Option<Result<Expression, ComputeError>>

获取任务结果

pub fn pending_count(&self) -> usize

获取待执行任务数量

pub fn running_count(&self) -> usize

获取正在执行任务数量

pub fn completed_count(&self) -> usize

获取已完成任务数量

pub fn cleanup_completed(&self)

清理已完成的任务

Trait Implementations

impl Debug for TaskScheduler

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

Formats the value using the given formatter.