Struct work_queue::LocalQueue

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

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.

#[must_use]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.

#[must_use]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.