Struct cros_async::queue::RunnableQueue

pub struct RunnableQueue {
    runnables: Mutex<VecDeque<Runnable>>,
}

A queue of Runnables. Intended to be used by executors to keep track of futures that have been scheduled to run.

Fields

runnables: Mutex<VecDeque<Runnable>>

Implementations

impl RunnableQueue

pub fn new() -> RunnableQueue

Create a new, empty RunnableQueue.

pub fn push_back(&self, runnable: Runnable)

Schedule runnable to run in the future by adding it to this RunnableQueue.

pub fn pop_front(&self) -> Option<Runnable>

Remove and return the first Runnable in this RunnableQueue or None if it is empty.

pub fn iter(&self) -> RunnableQueueIter<'_>

Create an iterator over this RunnableQueue that repeatedly calls pop_front() until it is empty.

Trait Implementations

impl Default for RunnableQueue

fn default() -> Self

Returns the “default value” for a type.

impl<'q> IntoIterator for &'q RunnableQueue

type Item = Runnable

The type of the elements being iterated over.

type IntoIter = RunnableQueueIter<'q>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.