Searched defs:local_queue (Results 1 – 2 of 2) sorted by relevance
737 let local_queue = LocalQueue::new(); in ut_inner_buffer_push_back() localVariable771 let local_queue = LocalQueue::new(); in ut_inner_buffer_push_back() localVariable824 let local_queue = LocalQueue::new(); in ut_inner_buffer_pop_front() localVariable830 let local_queue = Arc::new(LocalQueue::new()); in ut_inner_buffer_pop_front() localVariable869 let local_queue = Arc::new(LocalQueue::new()); in ut_inner_buffer_pop_front() localVariable915 let local_queue = LocalQueue::new(); in ut_inner_buffer_steal_into_zero() localVariable934 let local_queue = LocalQueue::new(); in ut_inner_buffer_steal_into_less_than_half() localVariable967 let local_queue = Arc::new(LocalQueue::new()); in ut_inner_buffer_steal_into_multi_thread() localVariable1071 let local_queue = LocalQueue::new(); in ut_inner_buffer_steal_into_more_than_half() localVariable
438 let local_queue = self.exe_mng_info.create_local_queue(index); in create_async_thread_pool() localVariable824 let local_queue = LocalQueue { in ut_executor_mng_info_wake_up_rand_one() localVariable862 let local_queue = LocalQueue { in ut_executor_mng_info_wake_up_if_one_task_left() localVariable919 let local_queue = LocalQueue { in ut_executor_mng_info_from_woken_to_sleep() localVariable