Struct Runner 

pub(crate) struct Runner<'a> {
    pub(crate) state: &'a State,
    pub(crate) ticker: Ticker<'a>,
    pub(crate) local: Arc<ConcurrentQueue<Runnable>>,
    pub(crate) ticks: usize,
}

A worker in a work-stealing executor.

This is just a ticker that also has an associated local queue for improved cache locality.

Fields

state: &'a State

The executor state.

ticker: Ticker<'a>

Inner ticker.

local: Arc<ConcurrentQueue<Runnable>>

The local queue.

ticks: usize

Bumped every time a runnable task is found.

Implementations

impl Runner<'_>

pub(crate) fn new(state: &State) -> Runner<'_>

Creates a runner and registers it in the executor state.

pub(crate) async fn runnable(&mut self, rng: &mut Rng) -> Runnable

Waits for the next runnable task to run.

Trait Implementations

impl Drop for Runner<'_>

fn drop(&mut self)

Executes the destructor for this type.