Struct tokio_executor::park::ParkThread

[+] Show declaration

pub struct ParkThread { /* fields omitted */ }

[−] Expand description

Blocks the current thread using a condition variable.

Implements the [Park] functionality by using a condition variable. An atomic variable is also used to avoid using the condition variable if possible.

The condition variable is cached in a thread-local variable and is shared across all ParkThread instances created on the same thread. This also means that an instance of ParkThread might be unblocked by a handle associated with a different ParkThread instance.

Methods

impl ParkThread

[−]

pub fn new() -> ParkThread

[−]

Create 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.

Trait Implementations

impl Park for ParkThread

[+]

type Unpark = UnparkThread

Unpark handle type for the Park implementation.

type Error = ParkError

Error returned by park

fn unpark(&self) -> Self::Unpark

[−]

Get a new Unpark handle associated with this Park instance.

fn park(&mut self) -> Result<(), Self::Error>

[−]

Block the current thread unless or until the token is available.

fn park_timeout(&mut self, duration: Duration) -> Result<(), Self::Error>

[−]

Park the current thread for at most duration.

impl Debug for ParkThread

[+]

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

[−]

Formats the value using the given formatter.