Struct tokio::runtime::park::CachedParkThread

pub(crate) struct CachedParkThread {
    _anchor: PhantomData<Rc<()>>,
}

Blocks the current thread using a condition variable.

Fields

_anchor: PhantomData<Rc<()>>

Implementations

impl CachedParkThread

pub(crate) fn new() -> CachedParkThread

Creates a new ParkThread handle for the current thread.

This type cannot be moved to other threads, so it should be created on the thread that the caller intends to park.

pub(crate) fn waker(&self) -> Result<Waker, AccessError>

fn unpark(&self) -> Result<UnparkThread, AccessError>

pub(crate) fn park(&mut self)

pub(crate) fn park_timeout(&mut self, duration: Duration)

fn with_current<F, R>(&self, f: F) -> Result<R, AccessError>

where F: FnOnce(&ParkThread) -> R,

Gets a reference to the ParkThread handle for this thread.

pub(crate) fn block_on<F: Future>( &mut self, f: F, ) -> Result<F::Output, AccessError>

Trait Implementations

impl Debug for CachedParkThread

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

Formats the value using the given formatter.