Struct tokio::runtime::scheduler::inject::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 len(&self) -> usize

impl<T: 'static> Inject<T>

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

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>>