Struct tokio::runtime::scheduler::current_thread::CurrentThread

pub(crate) struct CurrentThread {
    core: AtomicCell<Core>,
    notify: Notify,
}

Executes tasks on the current thread

Fields

core: AtomicCell<Core>

Core scheduler data is acquired by a thread entering block_on.

notify: Notify

Notifier for waking up other threads to steal the driver.

Implementations

impl CurrentThread

pub(crate) fn new( driver: Driver, driver_handle: Handle, blocking_spawner: Spawner, seed_generator: RngSeedGenerator, config: Config, local_tid: Option<ThreadId>, ) -> (CurrentThread, Arc<Handle>)

pub(crate) fn block_on<F: Future>( &self, handle: &Handle, future: F, ) -> F::Output

fn take_core(&self, handle: &Arc<Handle>) -> Option<CoreGuard<'_>>

pub(crate) fn shutdown(&mut self, handle: &Handle)

Trait Implementations

impl Debug for CurrentThread

fn fmt(&self, fmt: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.