Searched defs:LocalQueue (Results 1 – 3 of 3) sorted by relevance
38 pub(crate) struct LocalQueue { struct42 unsafe impl Send for LocalQueue {} implementation43 unsafe impl Sync for LocalQueue {} implementation48 impl LocalQueue { implementation76 impl LocalQueue { impl104 impl LocalQueue { impl473 queue: &LocalQueue, in pop_batch()578 impl LocalQueue { impl613 impl LocalQueue { implementation621 fn steal_into_and_release(&self, other: &LocalQueue) { in steal_into_and_release()
236 pub(crate) fn new(run_queues: LocalQueue, parker: Parker) -> Self { in new()
160 pub(crate) fn create_local_queue(&self, index: usize) -> LocalQueue { in create_local_queue()