Struct WorkerHandle 

pub struct WorkerHandle { /* private fields */ }

Handle for a worker to interact with the scheduler.

Provides a simpler API for workers with integrated work-stealing.

Implementations

impl WorkerHandle

pub fn new(scheduler: Arc<MorselScheduler>) -> Self

Creates a new worker handle and registers with the scheduler.

pub fn get_work(&self) -> Option<Morsel>

Gets the next morsel to process.

Tries: local queue -> global queue -> steal from others

pub fn push_local(&self, morsel: Morsel)

Pushes a morsel to this worker’s local queue.

pub fn complete_morsel(&self)

Marks the current morsel as complete.

pub fn worker_id(&self) -> usize

Returns the worker ID.

pub fn is_done(&self) -> bool

Returns whether all work is done.