Trait WorkStealingTask 

pub trait WorkStealingTask: Send + 'static {
    type Output: Send + 'static;

    // Required method
    fn execute(self) -> Self::Output;

    // Provided methods
    fn estimated_duration(&self) -> Option<Duration> { ... }
    fn estimated_memory(&self) -> Option<usize> { ... }
    fn can_split(&self) -> bool { ... }
    fn split(self) -> Vec<Box<dyn WorkStealingTask<Output = Self::Output>>>
       where Self: Sized { ... }
}

A task that can be executed by the work-stealing scheduler

Required Associated Types

type Output: Send + 'static

The result type produced by this task

Required Methods

fn execute(self) -> Self::Output

Execute the task and return the result

Provided Methods

fn estimated_duration(&self) -> Option<Duration>

Get the estimated execution time (for load balancing)

fn estimated_memory(&self) -> Option<usize>

Get the estimated memory usage (for NUMA scheduling)

fn can_split(&self) -> bool

Check if this task can be split into smaller tasks

fn split(self) -> Vec<Box<dyn WorkStealingTask<Output = Self::Output>>>

where Self: Sized,

Split this task into smaller tasks (if supported)

Implementors