Struct Acquire 

pub(crate) struct Acquire<'a> {
    node: Waiter,
    semaphore: &'a Semaphore,
    num_permits: usize,
    queued: bool,
}

Fields

node: Waiter

semaphore: &'a Semaphore

num_permits: usize

queued: bool

Whether Acquire::drop must clean up after the waiter, by removing it from the wait queue if it is still linked and returning the permits assigned to it to the semaphore.

This is set as soon as poll_acquire assigns permits to the waiter or links it into the wait queue, and it is only cleared once the future completes and the permits are handed to the caller.

Implementations

impl<'a> Acquire<'a>

fn new(semaphore: &'a Semaphore, num_permits: usize) -> Self

fn project( self: Pin<&mut Self>, ) -> (Pin<&mut Waiter>, &Semaphore, usize, &mut bool)

Trait Implementations

impl Drop for Acquire<'_>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl Future for Acquire<'_>

type Output = Result<(), AcquireError>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl Sync for Acquire<'_>