Struct WorkStealingQueue 

pub struct WorkStealingQueue<T> { /* private fields */ }

Work-stealing deque for load balancing

Implementations

impl<T> WorkStealingQueue<T>

where T: Send + 'static + Clone,

pub fn new(num_workers: usize) -> Self

Create a new work-stealing queue system

pub fn push_local(&self, task: T) -> UtilsResult<()>

Push a task to the local queue

pub fn push_global(&self, task: T) -> UtilsResult<()>

Push a task to the global queue

pub fn pop_local(&self) -> UtilsResult<Option<T>>

Pop a task from the local queue

pub fn steal_work(&self) -> UtilsResult<Option<T>>

Steal work from other workers’ queues

pub fn get_task(&self) -> UtilsResult<Option<T>>

Get the next task, trying local queue first, then stealing

Trait Implementations

impl<T: Debug> Debug for WorkStealingQueue<T>

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

Formats the value using the given formatter.