Searched refs: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 { impl50 LocalQueue { in new()76 impl LocalQueue { implementation104 impl LocalQueue { impl473 queue: &LocalQueue, in pop_batch() argument578 impl LocalQueue { impl613 impl LocalQueue { impl[all …]
24 use super::queue::{GlobalQueue, LocalQueue, LOCAL_QUEUE_CAP};52 locals: Vec<LocalQueue>,71 locals.push(LocalQueue::new()); in new()160 pub(crate) fn create_local_queue(&self, index: usize) -> LocalQueue { in create_local_queue() argument163 LocalQueue { in create_local_queue()312 fn steal(&self, destination: &LocalQueue) -> Option<Task> { in steal()622 use crate::executor::queue::LocalQueue;824 let local_queue = LocalQueue { in ut_executor_mng_info_wake_up_rand_one()862 let local_queue = LocalQueue { in ut_executor_mng_info_wake_up_if_one_task_left()919 let local_queue = LocalQueue { in ut_executor_mng_info_from_woken_to_sleep()
23 use crate::executor::queue::LocalQueue;230 pub(crate) run_queue: LocalQueue,236 pub(crate) fn new(run_queues: LocalQueue, parker: Parker) -> Self { in new() argument