Home
last modified time | relevance | path

Searched refs:handles (Results 1 - 20 of 20) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dspawn.rs33 let mut handles = Vec::with_capacity(num); in sdv_one_core_test() variables
36 handles.push(ylong_runtime::spawn(test_future(i))); in sdv_one_core_test()
39 for (times, handle) in handles.into_iter().enumerate() { in sdv_one_core_test()
50 let mut handles = Vec::with_capacity(num); in sdv_two_core_test() variables
53 handles.push(ylong_runtime::spawn(test_future(i))); in sdv_two_core_test()
56 for (times, handle) in handles.into_iter().enumerate() { in sdv_two_core_test()
67 let mut handles = Vec::with_capacity(num); in sdv_three_core_test() variables
70 handles.push(ylong_runtime::spawn(test_future(i))); in sdv_three_core_test()
73 for (times, handle) in handles.into_iter().enumerate() { in sdv_three_core_test()
84 let mut handles in sdv_four_core_test() variables
101 let mut handles = Vec::with_capacity(num); sdv_eight_core_test() variables
118 let mut handles = Vec::with_capacity(num); sdv_max_core_test() variables
135 let mut handles = Vec::with_capacity(num); sdv_multi_future_in_async() variables
153 let mut handles = Vec::with_capacity(num); sdv_multi_async_in_async() variables
[all...]
H A Dspawn_blocking.rs27 let mut handles = Vec::with_capacity(num); in ffrt_spawn_blocking_test() variables
29 handles.push(ylong_runtime::spawn_blocking(move || { in ffrt_spawn_blocking_test()
35 for (times, handle) in handles.into_iter().enumerate() { in ffrt_spawn_blocking_test()
40 let mut handles = Vec::with_capacity(num); in ffrt_spawn_blocking_test() variables
43 handles.push(task_builder.spawn_blocking(move || { in ffrt_spawn_blocking_test()
49 for (times, handle) in handles.into_iter().enumerate() { in ffrt_spawn_blocking_test()
68 let mut handles = Vec::with_capacity(num); in test_spawn() variables
70 handles.push(runtime.spawn_blocking(move || { in test_spawn()
75 for (times, handle) in handles.into_iter().enumerate() { in test_spawn()
80 let mut handles in test_spawn() variables
93 let mut handles = Vec::with_capacity(num); test_spawn() variables
[all...]
H A Dsingleton_runtime.rs48 let mut handles = Vec::with_capacity(SPAWN_NUM); in sdv_concurrently_runtime_spawn_async_in_async_task() variables
50 handles.push(ylong_runtime::spawn(test_async_in_async(i, i + 1))); in sdv_concurrently_runtime_spawn_async_in_async_task()
52 for (times, handle) in handles.into_iter().enumerate() { in sdv_concurrently_runtime_spawn_async_in_async_task()
76 let mut handles = Vec::with_capacity(SPAWN_NUM); in sdv_concurrently_spawn_async_in_async_task() variables
78 handles.push(ylong_runtime::spawn(test_async_in_async(i, i + 1))); in sdv_concurrently_spawn_async_in_async_task()
80 for (times, handle) in handles.into_iter().enumerate() { in sdv_concurrently_spawn_async_in_async_task()
104 let mut handles = Vec::with_capacity(SPAWN_NUM); in sdv_concurrently_task_builder_spawn_async_in_async_task() variables
107 handles.push(task_builder.spawn(test_async_in_async(i, i + 1))); in sdv_concurrently_task_builder_spawn_async_in_async_task()
109 for (times, handle) in handles.into_iter().enumerate() { in sdv_concurrently_task_builder_spawn_async_in_async_task()
H A Dasync_pool.rs130 let handles = vec![ in sdv_async_pool_001()
149 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_001()
190 let handles = vec![ in sdv_async_pool_002()
209 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_002()
250 let handles = vec![ in sdv_async_pool_003()
269 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_003()
310 let handles = vec![ in sdv_async_pool_004()
329 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_004()
370 let handles = vec![ in sdv_async_pool_005()
389 for (times, handle) in handles in sdv_async_pool_005()
[all...]
H A Dsignal.rs69 let mut handles = Vec::new(); in sdv_signal_recv_multi_thread_test() variables
72 handles.push(ylong_runtime::spawn(async move { in sdv_signal_recv_multi_thread_test()
80 for handle in handles { in sdv_signal_recv_multi_thread_test()
113 let mut handles = Vec::new(); in sdv_signal_poll_recv_multi_thread_test() variables
116 handles.push(ylong_runtime::spawn(async move { in sdv_signal_poll_recv_multi_thread_test()
124 for handle in handles { in sdv_signal_poll_recv_multi_thread_test()
H A Dtimer_test.rs39 let mut handles = Vec::new(); variables
42 handles.push(ylong_runtime::spawn(async move {
47 for handle in handles {
H A Dyield.rs68 let mut handles = vec![]; in sdv_yield_now_single_worker() variables
81 handles.push(handle); in sdv_yield_now_single_worker()
84 for handle in handles { in sdv_yield_now_single_worker()
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/
H A Dylong_tokio_spawn.rs49 let mut handles = Vec::with_capacity(1000); in ylong_spawn() variables
55 handles.push(handle); in ylong_spawn()
59 for handle in handles { in ylong_spawn()
66 let mut handles = Vec::with_capacity(1000); in tokio_spawn() variables
73 handles.push(handle); in tokio_spawn()
77 for handle in handles { in tokio_spawn()
84 let mut handles = Vec::with_capacity(1000); in std_spawn() variables
90 handles.push(handle); in std_spawn()
94 for handle in handles { in std_spawn()
/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A Dylong_runtime_signal.rs40 let mut handles = Vec::new(); in run_multi_thread_signal() variables
43 handles.push(ylong_runtime::spawn(async move { in run_multi_thread_signal()
51 for handle in handles { in run_multi_thread_signal()
59 let mut handles = Vec::new(); in run_multi_thread_signal() variables
62 handles.push(ylong_runtime::spawn(async move { in run_multi_thread_signal()
71 for handle in handles { in run_multi_thread_signal()
/commonlibrary/rust/ylong_http/ylong_http_client/tests/
H A Dsdv_async_http_client_error.rs97 let mut handles = vec![]; in sdv_err_req_timeout() variables
103 Handles: handles, in sdv_err_req_timeout()
121 let handle = handles.pop().unwrap(); in sdv_err_req_timeout()
174 let mut handles = vec![]; in sdv_err_redirect_wrong_location() variables
180 Handles: handles, in sdv_err_redirect_wrong_location()
198 let handle = handles.pop().unwrap(); in sdv_err_redirect_wrong_location()
239 let mut handles = vec![]; in sdv_err_response_with_wrong_body_length() variables
245 Handles: handles, in sdv_err_response_with_wrong_body_length()
262 let handle = handles.pop().unwrap(); in sdv_err_response_with_wrong_body_length()
H A Dsdv_async_http_body_io.rs35 let mut handles = vec![]; in sdv_body_chunk_and_trailer() variables
41 Handles: handles, in sdv_body_chunk_and_trailer()
66 let handle = handles.pop().unwrap(); in sdv_body_chunk_and_trailer()
/commonlibrary/rust/ylong_http/ylong_http_client/examples/
H A Dasync_http_multi.rs22 let mut handles = Vec::new(); in main() variables
24 handles.push(ylong_runtime::spawn(async move { in main()
37 for handle in handles { in main()
H A Dasync_certs_adapter.rs43 let mut handles = Vec::new(); in main() variables
54 handles.push(ylong_runtime::spawn(request(temp))); in main()
56 for handle in handles { in main()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Ddispatcher.rs243 pub(crate) handles: Vec<crate::runtime::JoinHandle<()>>,
321 let mut handles = Vec::with_capacity(3); variables
329 &mut handles,
337 handles,
348 handles: &mut Vec<crate::runtime::JoinHandle<()>>, in launch()
364 handles.push(send); in launch()
372 handles.push(recv); in launch()
379 handles.push(manager); in launch()
404 for handle in &self.handles { in drop()
696 pub(crate) handles
745 let mut handles = Vec::with_capacity(2); global() variables
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/
H A Dmod.rs548 let mut handles = vec![]; in ut_ssl_tunnel_error() variables
550 Handles: handles, in ut_ssl_tunnel_error()
554 let handle = handles.pop().expect("No more handles !"); in ut_ssl_tunnel_error()
582 Handles: handles, in ut_ssl_tunnel_error()
592 let handle = handles.pop().expect("No more handles !"); in ut_ssl_tunnel_error()
622 Handles: handles, in ut_ssl_tunnel_error()
632 let handle = handles.pop().expect("No more handles !"); in ut_ssl_tunnel_error()
667 let mut handles = vec![]; ut_ssl_tunnel_connect() variables
711 let mut handles = vec![]; ut_ssl_tunnel_resp_beyond_size() variables
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dasync_pool.rs46 handles: RwLock<Vec<Parker>>,
77 handles: RwLock::new(Vec::new()),
101 let join_handle = self.handles.read().unwrap(); in wake_up_all()
132 self.handles
345 &self.handles
468 self.exe_mng_info.handles.write().unwrap().push(parker); in create_async_thread_pool()
516 /// when the function ends, any handles returned from this function rely
586 let mut join_handle = self.exe_mng_info.handles.write().unwrap();
665 assert_eq!(executor_mng_info.handles.read().unwrap().capacity(), 0); in ut_executor_mng_info_new_001()
669 assert_eq!(executor_mng_info.handles in ut_executor_mng_info_new_001()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/
H A Dselector.rs368 self.poll_info.handles[0].handle = self.base_socket as HANDLE; in update_while_idle()
369 self.poll_info.handles[0].status = 0; in update_while_idle()
370 self.poll_info.handles[0].events = self.user_interests_flags | afd::POLL_LOCAL_CLOSE; in update_while_idle()
473 } else if self.poll_info.handles[0].events & afd::POLL_LOCAL_CLOSE != 0 { in sock_feed_event()
478 afd_events = self.poll_info.handles[0].events; in sock_feed_event()
H A Dafd.rs241 pub handles: [AfdPollHandleInfo; 1],
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/
H A Dmod.rs452 let mut handles = Vec::new(); in ut_signal_recv_and_poll_recv() variables
453 handles.push(crate::spawn(async move { in ut_signal_recv_and_poll_recv()
458 handles.push(crate::spawn(async move { in ut_signal_recv_and_poll_recv()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/
H A Dwheel.rs257 let mut handles = self.levels[expiration.level].take_slot(expiration.slot); variables
258 while let Some(mut item) = handles.pop_back() {

Completed in 12 milliseconds