Struct tokio::runtime::scheduler::current_thread::Core

struct Core {
    tasks: VecDeque<Notified<Arc<Handle>>>,
    tick: u32,
    driver: Option<Driver>,
    metrics: MetricsBatch,
    global_queue_interval: u32,
    unhandled_panic: bool,
}

Data required for executing the scheduler. The struct is passed around to a function that will perform the scheduling work and acts as a capability token.

Fields

tasks: VecDeque<Notified<Arc<Handle>>>

Scheduler run queue

tick: u32

Current tick

driver: Option<Driver>

Runtime driver

The driver is removed before starting to park the thread

metrics: MetricsBatch

Metrics batch

global_queue_interval: u32

How often to check the global queue

unhandled_panic: bool

True if a task panicked without being handled and the runtime is configured to shutdown on unhandled panic.

Implementations

impl Core

fn tick(&mut self)

Get and increment the current tick

fn next_task(&mut self, handle: &Handle) -> Option<Notified<Arc<Handle>>>

fn next_local_task(&mut self, handle: &Handle) -> Option<Notified<Arc<Handle>>>

fn push_task(&mut self, handle: &Handle, task: Notified<Arc<Handle>>)

fn submit_metrics(&mut self, handle: &Handle)