Searched refs:other_local_queue (Results 1 – 1 of 1) sorted by relevance
916 let other_local_queue = LocalQueue::new(); in ut_inner_buffer_steal_into_zero() localVariable935 let other_local_queue = LocalQueue::new(); in ut_inner_buffer_steal_into_less_than_half() localVariable946 other_local_queue.push_back(task, &global_queue); in ut_inner_buffer_steal_into_less_than_half()949 other_local_queue.steal_into_and_release(&local_queue); in ut_inner_buffer_steal_into_less_than_half()970 let other_local_queue = Arc::new(LocalQueue::new()); in ut_inner_buffer_steal_into_multi_thread() localVariable983 other_local_queue.push_back(task, &global_queue); in ut_inner_buffer_steal_into_multi_thread()1000 other_local_queue.len() + local_queue.len() + 1, in ut_inner_buffer_steal_into_multi_thread()1027 let other_local_queue = Arc::new(LocalQueue::new()); in ut_inner_buffer_steal_into_multi_threaded_complex() localVariable1039 other_local_queue.push_back(task, &global_queue); in ut_inner_buffer_steal_into_multi_threaded_complex()1072 let other_local_queue = LocalQueue::new(); in ut_inner_buffer_steal_into_more_than_half() localVariable[all …]