| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| D | ylong_tokio_spawn.rs | 54 let handle = ylong_runtime::spawn(async_task()); in ylong_spawn() localVariable
55 handles.push(handle); in ylong_spawn()
59 for handle in handles { in ylong_spawn()
60 let _ = ylong_runtime::block_on(handle); in ylong_spawn()
72 let handle = runtime.spawn(async_task()); in tokio_spawn() localVariable
73 handles.push(handle); in tokio_spawn()
77 for handle in handles { in tokio_spawn()
78 let _ = runtime.block_on(handle); in tokio_spawn()
89 let handle = spawn(task); in std_spawn() localVariable
90 handles.push(handle); in std_spawn()
[all …]
|
| D | ylong_tokio_tcp_perf.rs | 36 let handle = runtime.spawn(async move { in ylong_create_client() localVariable
64 runtime.block_on(handle).unwrap(); in ylong_create_client()
73 let handle = runtime.spawn(async move { in tokio_create_client() localVariable
100 runtime.block_on(handle).unwrap(); in tokio_create_client()
113 let handle = runtime.spawn(async move { in main() localVariable
138 runtime.block_on(handle).unwrap(); in main()
157 let handle = runtime.spawn(async move { in main() localVariable
182 runtime.block_on(handle).unwrap(); in main()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | spawn.rs | 39 for (times, handle) in handles.into_iter().enumerate() { in sdv_one_core_test()
40 let ret = ylong_runtime::block_on(handle); in sdv_one_core_test()
56 for (times, handle) in handles.into_iter().enumerate() { in sdv_two_core_test()
57 let ret = ylong_runtime::block_on(handle); in sdv_two_core_test()
73 for (times, handle) in handles.into_iter().enumerate() { in sdv_three_core_test()
74 let ret = ylong_runtime::block_on(handle); in sdv_three_core_test()
90 for (times, handle) in handles.into_iter().enumerate() { in sdv_four_core_test()
91 let ret = ylong_runtime::block_on(handle); in sdv_four_core_test()
107 for (times, handle) in handles.into_iter().enumerate() { in sdv_eight_core_test()
108 let ret = ylong_runtime::block_on(handle); in sdv_eight_core_test()
[all …]
|
| D | task_cancel.rs | 34 let handle = ylong_runtime::spawn(async move { in sdv_task_cancel_simple() localVariable
43 ylong_runtime::block_on(handle).unwrap(); in sdv_task_cancel_simple()
56 let handle = ylong_runtime::spawn(async move { in sdv_task_cancel_failed() localVariable
63 ylong_runtime::block_on(handle).unwrap(); in sdv_task_cancel_failed()
95 let handle = ylong_runtime::spawn(async move { in sdv_task_cancel_multiple() localVariable
100 handle.cancel(); in sdv_task_cancel_multiple()
101 let res = handle.await; in sdv_task_cancel_multiple()
|
| D | async_fs.rs | 30 let handle = ylong_runtime::spawn(async move { in sdv_async_fs_write() localVariable
37 ylong_runtime::block_on(handle).unwrap(); in sdv_async_fs_write()
58 let handle = ylong_runtime::spawn(async move { in sdv_async_fs_read() localVariable
71 ylong_runtime::block_on(handle).unwrap(); in sdv_async_fs_read()
92 let handle = ylong_runtime::spawn(async move { in sdv_async_fs_rw() localVariable
95 ylong_runtime::block_on(handle).unwrap(); in sdv_async_fs_rw()
97 let handle = ylong_runtime::spawn(async move { in sdv_async_fs_rw() localVariable
115 ylong_runtime::block_on(handle).unwrap(); in sdv_async_fs_rw()
159 let handle = ylong_runtime::spawn(async move { in sdv_async_fs_read_to_end() localVariable
165 ylong_runtime::block_on(handle).unwrap(); in sdv_async_fs_read_to_end()
[all …]
|
| D | mpsc_test.rs | 30 let handle = ylong_runtime::spawn(async move { in sdv_unbounded_send_recv_test() localVariable
38 let _ = ylong_runtime::block_on(handle); in sdv_unbounded_send_recv_test()
66 let handle = ylong_runtime::spawn(async move { in sdv_unbounded_send_recv_timeout_test() localVariable
74 let _ = ylong_runtime::block_on(handle); in sdv_unbounded_send_recv_timeout_test()
86 let handle = ylong_runtime::spawn(async move { in sdv_bounded_send_recv_test() localVariable
96 let _ = ylong_runtime::block_on(handle); in sdv_bounded_send_recv_test()
129 let handle = ylong_runtime::spawn(async move { in sdv_bounded_send_timeout_recv_timeout_test() localVariable
138 let _ = ylong_runtime::block_on(handle); in sdv_bounded_send_timeout_recv_timeout_test()
245 let handle = ylong_runtime::spawn(async move { in sdv_multi_send_recv_test() localVariable
254 let _ = ylong_runtime::block_on(handle); in sdv_multi_send_recv_test()
[all …]
|
| D | udp_test.rs | 31 let handle = ylong_runtime::spawn(async move { in sdv_udp_send_recv() localVariable
73 ylong_runtime::block_on(handle).expect("block_on failed"); in sdv_udp_send_recv()
87 let handle = ylong_runtime::spawn(async move { in sdv_udp_send_to_recv_from() localVariable
116 ylong_runtime::block_on(handle).expect("block_on failed"); in sdv_udp_send_to_recv_from()
122 let handle = ylong_runtime::spawn(async move { in sdv_udp_send() localVariable
146 ylong_runtime::block_on(handle).expect("block_on failed"); in sdv_udp_send()
161 let handle = ylong_runtime::spawn(async move { in sdv_udp_recv() localVariable
181 ylong_runtime::block_on(handle).expect("block_on failed"); in sdv_udp_recv()
196 let handle = ylong_runtime::spawn(async move { in sdv_udp_try_recv_from() localVariable
237 ylong_runtime::block_on(handle).expect("block_on failed"); in sdv_udp_try_recv_from()
[all …]
|
| D | async_pool.rs | 126 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_001()
127 let result = runtime.block_on(handle).unwrap(); in sdv_async_pool_001()
186 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_002()
187 let result = runtime.block_on(handle).unwrap(); in sdv_async_pool_002()
246 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_003()
247 let result = runtime.block_on(handle).unwrap(); in sdv_async_pool_003()
306 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_004()
307 let result = runtime.block_on(handle).unwrap(); in sdv_async_pool_004()
366 for (times, handle) in handles.into_iter().enumerate() { in sdv_async_pool_005()
367 let result = runtime.block_on(handle).unwrap(); in sdv_async_pool_005()
[all …]
|
| D | spawn_blocking.rs | 33 for (times, handle) in handles.into_iter().enumerate() { in test_spawn()
34 let ret = runtime.block_on(handle); in test_spawn()
46 for (times, handle) in handles.into_iter().enumerate() { in test_spawn()
47 let ret = runtime.block_on(handle); in test_spawn()
60 for (times, handle) in handles.into_iter().enumerate() { in test_spawn()
61 let ret = runtime.block_on(handle); in test_spawn()
|
| D | singleton_runtime.rs | 52 for (times, handle) in handles.into_iter().enumerate() { in sdv_concurrently_runtime_spawn_async_in_async_task()
53 let ret = ylong_runtime::block_on(handle); in sdv_concurrently_runtime_spawn_async_in_async_task()
80 for (times, handle) in handles.into_iter().enumerate() { in sdv_concurrently_spawn_async_in_async_task()
81 let ret = ylong_runtime::block_on(handle); in sdv_concurrently_spawn_async_in_async_task()
109 for (times, handle) in handles.into_iter().enumerate() { in sdv_concurrently_task_builder_spawn_async_in_async_task()
110 let ret = ylong_runtime::block_on(handle); in sdv_concurrently_task_builder_spawn_async_in_async_task()
|
| D | join_set.rs | 96 let handle = ylong_runtime::spawn(async move { in sdv_join_set_spawn_io() localVariable
125 ylong_runtime::block_on(handle).unwrap(); in sdv_join_set_spawn_io()
138 let handle = ylong_runtime::spawn(async move { in sdv_join_set_spawn_multiple() localVariable
147 ylong_runtime::block_on(handle).unwrap(); in sdv_join_set_spawn_multiple()
193 let handle = set.spawn(async move { in sdv_join_set_cancel_one() localVariable
197 assert!(!handle.is_finished()); in sdv_join_set_cancel_one()
198 handle.cancel(); in sdv_join_set_cancel_one()
201 assert!(handle.is_finished()); in sdv_join_set_cancel_one()
|
| D | builder.rs | 47 let handle = runtime.spawn(test_future(1)); in sdv_set_builder_after_start() localVariable
48 let _result = runtime.block_on(handle).unwrap(); in sdv_set_builder_after_start()
75 let handle = runtime.spawn(test_future(1)); in sdv_set_builder_before_stop() localVariable
76 let _result = runtime.block_on(handle).unwrap(); in sdv_set_builder_before_stop()
|
| D | semaphore_test.rs | 31 let handle = ylong_runtime::spawn(async move { in auto_release_sem_acquire_test() localVariable
35 ylong_runtime::block_on(handle).expect("block_on failed"); in auto_release_sem_acquire_test()
88 let handle = ylong_runtime::spawn(async move { in auto_release_sem_close_test() localVariable
92 ylong_runtime::block_on(handle).expect("block_on failed"); in auto_release_sem_close_test()
187 let handle = ylong_runtime::spawn(async move { in acquire_test() localVariable
192 ylong_runtime::block_on(handle).expect("block_on failed"); in acquire_test()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| D | iocp.rs | 31 handle: Handle, field
37 let handle = unsafe { CreateIoCompletionPort(INVALID_HANDLE_VALUE, 0, 0, 0) }; in new() localVariable
38 if handle == 0 { in new()
42 handle: Handle::new(handle), in new()
53 CreateIoCompletionPort(t.as_raw_handle() as HANDLE, self.handle.raw(), token, 0), in add_handle()
77 self.handle.raw(), in get_results()
96 self.handle.raw(), in post()
108 self.handle.into_raw() in into_raw_handle()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| D | join_set.rs | 83 handle: UnsafeCell<ManuallyDrop<JoinHandle<R>>>, field
103 unsafe { (*(self.handle.get())).raw.eq(&(*(other.handle.get())).raw) } in eq()
111 unsafe { (*self.handle.get()).raw.hash(state) } in hash()
169 let handle = match builder { in spawn_inner() localVariable
173 let cancel = handle.get_cancel_handle(); in spawn_inner()
175 handle: UnsafeCell::new(ManuallyDrop::new(handle)), in spawn_inner()
185 (*entry.handle.get()).set_waker(&waker); in spawn_inner()
245 unsafe { (*item.handle.get()).cancel() } in cancel_all()
248 unsafe { (*item.handle.get()).cancel() } in cancel_all()
313 match Pin::new(&mut **(entry.handle.get())).poll(&mut ctx) { in poll_join_next()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/ |
| D | select.rs | 175 $( ( $index:expr, $($_i:tt)* ) $bind:pat = $fut:expr, if $c:expr => $handle:expr, )+
265 … $crate::tuple_form!(($count) with Out::Fail except Out::Finish($bind) at ($($_i)*)) => $handle,
362 let handle = crate::spawn(async { in new_select_basic() localVariable
382 crate::block_on(handle).expect("select! fail"); in new_select_basic()
395 let handle = crate::spawn(async { in new_select_channel() localVariable
422 crate::block_on(handle).expect("select! fail"); in new_select_channel()
432 let handle = crate::spawn(async { in new_select_biased() localVariable
462 crate::block_on(handle).expect("select! fail"); in new_select_biased()
485 let handle = crate::spawn(async { in new_select_match() localVariable
505 crate::block_on(handle).expect("select! fail"); in new_select_match()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| D | timeout.rs | 120 let handle = spawn(not_elapsed()); in ut_timeout_test() localVariable
121 let result = block_on(handle).unwrap(); in ut_timeout_test()
124 let handle = spawn(elapsed()); in ut_timeout_test() localVariable
125 let result = block_on(handle).unwrap(); in ut_timeout_test()
141 let handle = spawn(simple()); in ut_timeout_test_002() localVariable
142 block_on(handle).unwrap(); in ut_timeout_test_002()
|
| D | sleep.rs | 89 handle: Arc<Handle>, field
96 let handle = Handle::get_handle().expect("sleep new out of worker ctx"); in new_timeout() localVariable
99 let handle = TimeDriver::get_ref(); in new_timeout() localVariable
101 let start_time = handle.start_time(); in new_timeout()
110 handle, in new_timeout()
129 let driver = &self.handle; in cancel()
143 let driver = &this.handle; in poll()
|
| D | timer.rs | 200 let handle = spawn(async move { in ut_new_timer_base() localVariable
214 block_on(handle).unwrap(); in ut_new_timer_base()
225 let handle = spawn(async move { in ut_new_timer_timeout() localVariable
240 block_on(handle).unwrap(); in ut_new_timer_timeout()
261 let handle = spawn(task); in ut_new_timer_schedule() localVariable
262 let _ = block_on(handle); in ut_new_timer_schedule()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | worker.rs | 79 pub(crate) fn run_worker(worker: Arc<Worker>, handle: Arc<Handle>) { in run_worker()
82 let cur_handle = WorkerHandle { _handle: handle }; in run_worker()
89 CURRENT_HANDLE.with(|handle| handle.set(self.1)); in run_worker()
97 let handle = CURRENT_HANDLE.with(|handle| { in run_worker() localVariable
98 let prev_handle = handle.get(); in run_worker()
99 handle.set(&cur_handle as *const _ as *const ()); in run_worker()
103 Reset(prev_ctx, handle) in run_worker()
|
| /commonlibrary/rust/ylong_runtime/docs/ |
| D | user_guide.md | 40 let handle = ylong_runtime::spawn(async move {
42 let handle = ylong_runtime::spawn(async move {
47 let res = handle.await.unwrap();
52 let res = ylong_runtime::block_on(handle).unwrap();
85 let handle = ylong_runtime::spawn(async move {
93 ylong_runtime::block_on(handle).unwrap();
107 let handle = ylong_runtime::spawn(async move {
140 let handle = ylong_runtime::spawn(async move {
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
| D | mod.rs | 62 let handle = start_http_server!( localVariable
66 tx.send(handle)
72 let handle = rx localVariable
75 $handle_vec.push(handle);
88 let mut handle = start_http_server!( localVariable
92 handle
97 tx.send(handle)
103 let handle = rx localVariable
106 $handle_vec.push(handle);
371 (ServerHandle: $handle:expr) => {
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/builder/ |
| D | mod.rs | 269 let handle = runtime.spawn(async move { index }); in ut_thread_pool_builder_current_thread() localVariable
270 handles.push(handle); in ut_thread_pool_builder_current_thread()
272 for (index, handle) in handles.into_iter().enumerate() { in ut_thread_pool_builder_current_thread()
273 let result = runtime.block_on(handle).unwrap(); in ut_thread_pool_builder_current_thread()
279 let handle = runtime.spawn(async move { index }); in ut_thread_pool_builder_current_thread() localVariable
280 let result = runtime.block_on(handle).unwrap(); in ut_thread_pool_builder_current_thread()
285 let handle = runtime.spawn(async move { in ut_thread_pool_builder_current_thread() localVariable
287 let handle = runtime.spawn(async move { 1_usize }); in ut_thread_pool_builder_current_thread() localVariable
288 let result = runtime.block_on(handle).unwrap(); in ut_thread_pool_builder_current_thread()
292 let result = runtime.block_on(handle).unwrap(); in ut_thread_pool_builder_current_thread()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| D | ylong_tokio_rwlock.rs | 74 let handle = ylong_runtime::spawn(async move {}); in ylong_rwlock_read() localVariable
75 let _ = ylong_runtime::block_on(handle); in ylong_rwlock_read()
123 let handle = ylong_runtime::spawn(async move {}); in ylong_rwlock_write() localVariable
124 let _ = ylong_runtime::block_on(handle); in ylong_rwlock_write()
180 let handle = ylong_runtime::spawn(async move {}); in ylong_rwlock_write_read() localVariable
181 let _ = ylong_runtime::block_on(handle); in ylong_rwlock_write_read()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| D | worker.cpp | 57 uv_close(reinterpret_cast<uv_handle_t*>(worker->performTaskSignal_), [](uv_handle_t* handle) { in ReleaseWorkerHandles() argument
58 if (handle != nullptr) { in ReleaseWorkerHandles()
59 delete reinterpret_cast<uv_async_t*>(handle); in ReleaseWorkerHandles()
60 handle = nullptr; in ReleaseWorkerHandles()
65 …_close(reinterpret_cast<uv_handle_t*>(worker->debuggerOnPostTaskSignal_), [](uv_handle_t* handle) { in ReleaseWorkerHandles() argument
66 if (handle != nullptr) { in ReleaseWorkerHandles()
67 delete reinterpret_cast<uv_async_t*>(handle); in ReleaseWorkerHandles()
68 handle = nullptr; in ReleaseWorkerHandles()
73 uv_close(reinterpret_cast<uv_handle_t*>(worker->clearWorkerSignal_), [](uv_handle_t* handle) { in ReleaseWorkerHandles() argument
74 if (handle != nullptr) { in ReleaseWorkerHandles()
[all …]
|