Searched defs:parker (Results 1 – 5 of 5) sorted by relevance
24 parker: AtomicUsize, field67 let parker = Arc::new(Parker::new(10)); in sdv_yield_now_single_worker() localVariable
212 let parker = unsafe { Arc::from_raw(ptr.cast::<Parker>()) }; in clone() localVariable222 let parker = unsafe { Arc::from_raw(ptr.cast::<Parker>()) }; in wake() localVariable227 let parker = unsafe { Arc::from_raw(ptr.cast::<Parker>()) }; in wake_by_ref() localVariable274 let parker = Arc::new(self.get_parker()); in block_on() localVariable
467 let parker = worker.inner.borrow().parker.clone(); in create_async_thread_pool() localVariable769 let mut parker = Parker::new(arc_driver); in ut_executor_mng_info_cancel() localVariable798 let mut parker = Parker::new(arc_driver); in ut_executor_mng_info_wake_up_all() localVariable822 let mut parker = Parker::new(arc_driver); in ut_executor_mng_info_wake_up_rand_one() localVariable859 let mut parker = Parker::new(arc_driver); in ut_executor_mng_info_wake_up_if_one_task_left() localVariable917 let mut parker = Parker::new(arc_driver); in ut_executor_mng_info_from_woken_to_sleep() localVariable
98 let parker = ThreadParker::new(); in block_on() localVariable
231 pub(crate) parker: Parker, field