pub fn consume_allocation(state: &AtomicUsize, ordering: Ordering) -> CanBlock {
        let state: Self = state.fetch_and(!ALLOCATED, ordering).into();

        if state.is_allocated() {
            CanBlock::Allocated
        } else if state.is_queued() {
            CanBlock::NoCapacity
        } else {
            CanBlock::CanRequest
        }
    }
/// Atomically consume the capacity allocation and return if the allocation
/// was present.
///
/// If this returns `true`, then the task has the ability to block for the
/// duration of the `poll`.
Atomically consume the capacity allocation and return if the allocation
was present.

If this returns `true`, then the task has the ability to block for the
duration of the `poll`.
Atomically consume the capacity allocation and return if the allocation was present . If this returns ` true ` then the task has the ability to block for the duration of the ` poll ` .
pub fn consume_allocation(state: &AtomicUsize, ordering: Ordering) -> CanBlock {
        let state: Self = state.fetch_and(!ALLOCATED, ordering).into();
        if state.is_allocated() {
            CanBlock::Allocated
        } else if state.is_queued() {
            CanBlock::NoCapacity
        } else {
            CanBlock::CanRequest
        }
    }
pub fn consume_allocation ( state : & AtomicUsize , ordering : Ordering ) -> CanBlock { let state : Self = state . fetch_and ( ! ALLOCATED , ordering ) . into ( ) ; if state . is_allocated ( ) { CanBlock :: Allocated } else if state . is_queued ( ) { CanBlock :: NoCapacity } else { CanBlock :: CanRequest } }
Atomically consume the capacity allocation and return if the allocation
was present.
Atomically consume the capacity allocation and return if the allocation was present .
state
&AtomicUsize
ordering
Ordering