Struct AcquireSlow 

struct AcquireSlow<B: Borrow<Mutex<T>>, T: ?Sized> {
    mutex: Option<B>,
    listener: Option<EventListener>,
    start: Start,
    starved: bool,
    _marker: PhantomData<T>,
    _pin: PhantomPinned,
}

Future for acquiring the mutex slowly.

Fields

mutex: Option<B>

listener: Option<EventListener>

start: Start

starved: bool

_marker: PhantomData<T>

_pin: PhantomPinned

Implementations

impl<T: ?Sized, B: Borrow<Mutex<T>>> AcquireSlow<B, T>

fn new(mutex: B) -> Self

Create a new AcquireSlow future.

fn take_mutex(self: Pin<&mut Self>) -> Option<B>

Take the mutex reference out, decrementing the counter if necessary.

Trait Implementations

impl<T: ?Sized, B: Borrow<Mutex<T>>> Drop for AcquireSlow<B, T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T: ?Sized, B: Unpin + Borrow<Mutex<T>>> EventListenerFuture for AcquireSlow<B, T>

type Output = B

The type of value produced on completion.

fn poll_with_strategy<'a, S: Strategy<'a>>( self: Pin<&mut Self>, strategy: &mut S, context: &mut S::Context, ) -> Poll<Self::Output>

Poll the future using the provided strategy.

fn wait(self) -> Self::Output

where Self: Sized,

Wait for the future to complete, blocking the current thread.

impl<'__pin, B: Borrow<Mutex<T>>, T: ?Sized> Unpin for AcquireSlow<B, T>

where PinnedFieldsOf<__Origin<'__pin, B, T>>: Unpin,