Struct WakerShared 

struct WakerShared<const LEN: usize>
where
    Const<LEN>: Internal,
{
    waker: AtomicWaker,
    active: GenericArray<AtomicUsize, <Const<LEN> as Internal>::LengthInWords>,
}

Data shared between multiple BitWakers associated with a single Executor.

Fields

waker: AtomicWaker

The outer Waker that this Executor is currently associated with.

active: GenericArray<AtomicUsize, <Const<LEN> as Internal>::LengthInWords>

Each bit stores the flag for a sub-future of an Executor, to determine which need to run on each poll.

Implementations

impl<const LEN: usize> WakerShared<LEN>

where Const<LEN>: Internal,

const fn new() -> Self

Creates a new WakerShared that can store the state of at least LEN sub-futures.

fn reset(&self, index: usize) -> bool

Clears the flag for the index sub-future, and returns the previous value.

fn reset_all(&self) -> impl Iterator<Item = usize> + use<'_, LEN>

Clears all flags and returns the indexes of any that were set.

fn set(&self, index: usize) -> bool

Sets the flag for the index sub-future, and returns the previous value, waking any currently registered outer waker in the process.

async fn register_current(&self)

Registers the Waker of the current context as to-be-woken when any sub-future wakes.

fn get_active_ref_and_mask(&self, index: usize) -> (&AtomicUsize, usize)

Gets the word that the index flag is stored in, and the mask to identify the flag within the word.

Trait Implementations

impl<const LEN: usize> Debug for WakerShared<LEN>

where Const<LEN>: Internal,

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

Formats the value using the given formatter.