Struct Inject 

pub(crate) struct Inject<T: 'static> {
    shared: Shared<T>,
    synced: Mutex<Synced>,
}

Growable, MPMC queue used to inject new tasks into the scheduler and as an overflow queue when the local, fixed-size, array queue overflows.

Fields

shared: Shared<T>

synced: Mutex<Synced>

Implementations

impl<T: 'static> Inject<T>

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

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

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

Pushes several values into the queue.

unsafe fn push_batch_inner( &self, batch_head: RawTask, batch_tail: RawTask, num: usize, )

Inserts several tasks that have been linked together into the queue.

The provided head and tail may be the same task. In this case, a single task is inserted.

Safety

The caller must own the Notified for each of the num tasks, and the tasks must be linked from batch_head to batch_tail through their queue_next fields, with batch_tail’s queue_next unset.

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. The queue lock is held while f runs, so any values f does not consume are removed from the queue and dropped before the lock is released.

impl<T: 'static> Inject<T>

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

impl<T: 'static> Inject<T>

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

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

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

Closes the injection queue, returns true if the queue is open when the transition is 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>>