Home
last modified time | relevance | path

Searched refs:ready_to_run_queue (Results 1 – 2 of 2) sorted by relevance

/external/rust/crates/futures-util/src/stream/futures_unordered/
Dmod.rs30 mod ready_to_run_queue; module
31 use self::ready_to_run_queue::{ReadyToRunQueue, Dequeue};
56 ready_to_run_queue: Arc<ReadyToRunQueue<Fut>>, field
128 ready_to_run_queue: Weak::new(), in new()
131 let ready_to_run_queue = Arc::new(ReadyToRunQueue { in new() localVariable
140 ready_to_run_queue, in new()
174 ready_to_run_queue: Arc::downgrade(&self.ready_to_run_queue), in push()
190 self.ready_to_run_queue.enqueue(ptr); in push()
391 &*self.ready_to_run_queue.stub as *const _ as *mut _ in pending_next_all()
422 self.ready_to_run_queue.waker.register(cx.waker()); in poll_next()
[all …]
Dtask.rs30 pub(super) ready_to_run_queue: Weak<ReadyToRunQueue<Fut>>, field
46 let inner = match arc_self.ready_to_run_queue.upgrade() { in wake_by_ref()