Home
last modified time | relevance | path

Searched refs:MultiThreadScheduler (Results 1 – 3 of 3) sorted by relevance

/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dasync_pool.rs40 pub(crate) struct MultiThreadScheduler { struct
58 impl Schedule for MultiThreadScheduler { argument
67 impl MultiThreadScheduler { impl
358 pub(crate) exe_mng_info: Arc<MultiThreadScheduler>,
667 let executor_mng_info = MultiThreadScheduler::new(64, arc_handle); in ut_executor_mng_info_new_001()
684 let executor_mng_info = MultiThreadScheduler::new(64, arc_handle); in ut_executor_mng_info_create_local_queues()
735 let executor_mng_info = MultiThreadScheduler::new(1, arc_handle); in ut_executor_mng_info_is_cancel()
749 let executor_mng_info = MultiThreadScheduler::new(1, arc_handle); in ut_executor_mng_info_set_cancel()
762 let executor_mng_info = MultiThreadScheduler::new(1, arc_handle); in ut_executor_mng_info_cancel()
791 let executor_mng_info = MultiThreadScheduler::new(1, arc_handle); in ut_executor_mng_info_wake_up_all()
[all …]
H A Dqueue.rs561 use crate::executor::async_pool::MultiThreadScheduler;
693 Arc::downgrade(&Arc::new(MultiThreadScheduler::new(1, arc_handle.clone()))); in ut_inner_buffer_len()
707 Arc::downgrade(&Arc::new(MultiThreadScheduler::new(1, arc_handle.clone()))); in ut_inner_buffer_len()
745 Arc::downgrade(&Arc::new(MultiThreadScheduler::new(2, arc_handle.clone()))); in ut_inner_buffer_push_back()
757 Arc::downgrade(&Arc::new(MultiThreadScheduler::new(2, arc_handle.clone()))); in ut_inner_buffer_push_back()
778 Arc::downgrade(&Arc::new(MultiThreadScheduler::new(2, arc_handle.clone()))); in ut_inner_buffer_push_back()
790 Arc::downgrade(&Arc::new(MultiThreadScheduler::new(2, arc_handle.clone()))); in ut_inner_buffer_push_back()
932 let multi_scheduler = Arc::new(MultiThreadScheduler::new(1, arc_handle)); in ut_inner_buffer_steal_into_less_than_half()
965 let multi_scheduler = Arc::new(MultiThreadScheduler::new(1, arc_handle)); in ut_inner_buffer_steal_into_multi_thread()
1019 let multi_scheduler = Arc::new(MultiThreadScheduler::new(1, arc_handle)); in ut_inner_buffer_steal_into_multi_threaded_complex()
[all …]
H A Dworker.rs20 use crate::executor::async_pool::MultiThreadScheduler;
125 pub(crate) scheduler: Arc<MultiThreadScheduler>,