Enum InjectQueue 

pub(crate) enum InjectQueue<T: 'static> {
    Locked(Inject<T>),
}

The multi-thread scheduler’s inject queue. Each variant owns its queue and lock topology.

Variants

Locked(Inject<T>)

A single queue behind a single mutex.

Implementations

impl<T: 'static> InjectQueue<T>

pub(crate) fn new() -> InjectQueue<T>

pub(crate) fn is_empty(&self) -> bool

pub(crate) fn len(&self) -> usize

pub(crate) fn is_closed(&self) -> bool

pub(crate) fn close(&self) -> bool

Closes the queue, returns true if the queue was open when the transition was made.

pub(crate) fn push(&self, task: Notified<T>)

Pushes a value into the queue.

This does nothing if the queue is closed.

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

pub(crate) fn push_batch<I>(&self, iter: I)

where I: Iterator<Item = Notified<T>>,

Pushes several values into the queue.

This does nothing if the queue is closed.

pub(crate) fn pop_n<R>(&self, n: usize, f: impl FnOnce(Pop<'_, T>) -> R) -> R

Pops up to n values from the queue, passing an iterator over them to f. Any values f does not consume are removed from the queue and dropped.