Struct Queue 

pub struct Queue<'d, L = NonZero<usize>> { /* private fields */ }

Bounded FIFO wakes with a constructor-proved lane extent.

Implementations

impl<'d, L> Queue<'d, L>

pub fn try_new( driver: Reference<'d>, capacity: usize, lanes: L, ) -> Result<Self, Error>

where L: Extent,

impl<'d> Queue<'d>

pub fn try_with<S, R>( driver: Reference<'d>, capacity: usize, lanes: NonZero<usize>, source: S, run: impl for<'scope> FnOnce(&'scope S, Queue<'d, Scope<'scope>>) -> R, ) -> Result<R, Error>

Creates one queue and borrows its source under a fresh invariant scope.

pub fn try_register<'target>( &'target self, position: usize, slot: &mut Registration<'target, 'd>, wake: &Waker<'d>, ) -> Result<(), Error>

pub fn try_wake_one( &self, position: usize, ) -> Result<Once, Bounds<NonZero<u32>>>

impl<'scope, 'd> Queue<'d, Scope<'scope>>

pub fn try_index( &self, position: usize, ) -> Result<Index<'scope>, Bounds<NonZero<u32>>>

pub fn try_register<'target>( &'target self, index: Index<'scope>, slot: &mut Registration<'target, 'd, Scope<'scope>>, wake: &Waker<'d>, ) -> Result<(), Reject>

pub fn wake_one(&self, index: Index<'scope>) -> Once

impl<'d, const N: usize> Queue<'d, Fixed<N>>

pub fn try_register<'target, const I: usize>( &'target self, slot: &mut Registration<'target, 'd, Fixed<N>>, wake: &Waker<'d>, ) -> Result<(), Reject>

pub fn wake_one<const I: usize>(&self) -> Once

impl<'d, L> Queue<'d, L>

pub fn cancel(&self, slot: &mut Registration<'_, 'd, L>) -> Once

Cancels the registration, forwarding a taken wake within its original lane. Active drains retain their work; successful admission uses clear.

pub fn try_first<'target>( &'target self, slot: &mut Registration<'target, 'd, L>, wake: &Waker<'d>, ) -> Result<(), Reject>

Registers one wake in the constructor-proved first lane.

pub fn wake_first(&self) -> Once

Wakes one registration from lane zero.

pub fn wake_next(&self) -> Once

pub fn has_waiters(&self) -> bool

pub fn begin_drain(&self)

pub fn is_draining(&self) -> bool

pub fn drain_one(&self, work: Work<'_, 'd>) -> Drain