Struct futures_util::stream::futures_unordered::ready_to_run_queue::ReadyToRunQueue

pub(super) struct ReadyToRunQueue<Fut> {
    pub(super) waker: AtomicWaker,
    pub(super) head: AtomicPtr<Task<Fut>>,
    pub(super) tail: UnsafeCell<*const Task<Fut>>,
    pub(super) stub: Arc<Task<Fut>>,
}

Fields

waker: AtomicWaker

head: AtomicPtr<Task<Fut>>

tail: UnsafeCell<*const Task<Fut>>

stub: Arc<Task<Fut>>

Implementations

impl<Fut> ReadyToRunQueue<Fut>

An MPSC queue into which the tasks containing the futures are inserted whenever the future inside is scheduled for polling.

pub(super) fn enqueue(&self, task: *const Task<Fut>)

The enqueue function from the 1024cores intrusive MPSC queue algorithm.

pub(super) unsafe fn dequeue(&self) -> Dequeue<Fut>

The dequeue function from the 1024cores intrusive MPSC queue algorithm

Note that this is unsafe as it required mutual exclusion (only one thread can call this) to be guaranteed elsewhere.

pub(super) fn stub(&self) -> *const Task<Fut>

Trait Implementations

impl<Fut> Drop for ReadyToRunQueue<Fut>

fn drop(&mut self)

Executes the destructor for this type.