Struct work_queue::LocalQueue

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

One of the local queues in a Queue.

You can create this using Queue::local_queues.

Implementations

impl<T> LocalQueue<T>

pub fn push(&mut self, item: T)

Push an item to the local queue. If the local queue is full, it will move half of its items to the global queue.

pub fn push_yield(&mut self, item: T)

Push an item to the local queue, skipping the LIFO slot. This can be used to give other tasks a chance to run. Otherwise, there’s a risk that one task will completely take over a thread in a push-pop cycle due to the LIFO slot.

pub fn pop(&mut self) -> Option<T>

Pop an item from the local queue, or steal from the global and sibling queues if it is empty.

pub fn searchers(&self) -> usize

Get the number of threads that are currently searching for work inside pop.

If this number is too high, you may wish to avoid calling pop to reduce contention.

pub fn global(&self) -> &Queue<T>

Get the global queue that is associated with this local queue.

Trait Implementations

impl<T: Debug> Debug for LocalQueue<T>

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

Formats the value using the given formatter.