Struct State 

pub(crate) struct State {
    pub(crate) queue: ConcurrentQueue<Runnable>,
    pub(crate) local_queues: RwLock<Vec<Arc<ConcurrentQueue<Runnable>>>>,
    pub(crate) notified: AtomicBool,
    pub(crate) sleepers: Mutex<Sleepers>,
    pub(crate) active: Mutex<Slab<Waker>>,
}

The state of a executor.

Fields

queue: ConcurrentQueue<Runnable>

The global queue.

local_queues: RwLock<Vec<Arc<ConcurrentQueue<Runnable>>>>

Local queues created by runners.

notified: AtomicBool

Set to true when a sleeping ticker is notified or no tickers are sleeping.

sleepers: Mutex<Sleepers>

A list of sleeping tickers.

active: Mutex<Slab<Waker>>

Currently active tasks.

Implementations

impl State

pub(crate) const fn new() -> Self

Creates state for a new executor.

pub(crate) fn pin(&self) -> Pin<&Self>

pub(crate) fn active(self: Pin<&Self>) -> MutexGuard<'_, Slab<Waker>>

Returns a reference to currently active tasks.

pub(crate) fn notify(&self)

Notifies a sleeping ticker.

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

pub(crate) async fn tick(&self)

pub async fn run<T>(&self, future: impl Future<Output = T>) -> T