Struct StealerRegistry 

pub struct StealerRegistry { /* private fields */ }

Shared stealer registry for work stealing between workers.

Implementations

impl StealerRegistry

pub fn new() -> Self

Create an empty stealer registry.

pub fn add_stealer(&self, worker_id: usize, stealer: Stealer<Task>)

Register a worker’s stealer under the given worker ID.

pub fn get_stealers(&self, exclude_worker_id: usize) -> Vec<Stealer<Task>>

Get stealers for all workers except exclude_worker_id.

pub fn version(&self) -> u64

Get the registry version (bumped on every add_stealer).

Trait Implementations

impl Clone for StealerRegistry

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for StealerRegistry

fn default() -> Self

Returns the “default value” for a type.