Struct tokio::util::idle_notified_set::IdleNotifiedSet

pub(crate) struct IdleNotifiedSet<T> {
    lists: Arc<Mutex<ListsInner<T>>>,
    length: usize,
}

This is the main handle to the collection.

Fields

lists: Arc<Mutex<ListsInner<T>>>

length: usize

Implementations

impl<T> IdleNotifiedSet<T>

pub(crate) fn new() -> Self

Create a new IdleNotifiedSet.

pub(crate) fn len(&self) -> usize

pub(crate) fn is_empty(&self) -> bool

pub(crate) fn insert_idle(&mut self, value: T) -> EntryInOneOfTheLists<'_, T>

Insert the given value into the idle list.

pub(crate) fn pop_notified( &mut self, waker: &Waker ) -> Option<EntryInOneOfTheLists<'_, T>>

Pop an entry from the notified list to poll it. The entry is moved to the idle list atomically.

pub(crate) fn try_pop_notified(&mut self) -> Option<EntryInOneOfTheLists<'_, T>>

Tries to pop an entry from the notified list to poll it. The entry is moved to the idle list atomically.

pub(crate) fn for_each<F: FnMut(&mut T)>(&mut self, func: F)

Call a function on every element in this list.

pub(crate) fn drain<F: FnMut(T)>(&mut self, func: F)

Remove all entries in both lists, applying some function to each element.

The closure is called on all elements even if it panics. Having it panic twice is a double-panic, and will abort the application.

Trait Implementations

impl<T> Drop for IdleNotifiedSet<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T: Send> Send for IdleNotifiedSet<T>

impl<T: Sync> Sync for IdleNotifiedSet<T>