| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | block_on.rs | 52 let runtime = RuntimeBuilder::new_multi_thread().build().unwrap(); in sdv_single1_block_on() localVariable
61 let runtime = RuntimeBuilder::new_multi_thread().build().unwrap(); in sdv_nest_block_on() localVariable
70 let runtime = RuntimeBuilder::new_multi_thread().build().unwrap(); in sdv_block_on_nest_spawn() localVariable
72 let runtime = RuntimeBuilder::new_multi_thread().build().unwrap(); in sdv_block_on_nest_spawn() localVariable
77 let runtime = RuntimeBuilder::new_multi_thread().build().unwrap(); in sdv_block_on_nest_spawn() localVariable
88 let runtime = RuntimeBuilder::new_multi_thread().build().unwrap(); in sdv_block_on_nest_spawn_spawn_blocking() localVariable
91 let runtime = RuntimeBuilder::new_multi_thread().build().unwrap(); in sdv_block_on_nest_spawn_spawn_blocking() localVariable
104 let runtime = RuntimeBuilder::new_multi_thread().build().unwrap(); in sdv_block_on_nest_spawn_spawn_blocking() localVariable
115 let runtime = RuntimeBuilder::new_multi_thread().build().unwrap(); in sdv_block_on_nest_spawn_and_spawn() localVariable
118 let runtime = RuntimeBuilder::new_multi_thread().build().unwrap(); in sdv_block_on_nest_spawn_and_spawn() localVariable
[all …]
|
| D | spawn_blocking.rs | 72 let runtime = RuntimeBuilder::new_multi_thread() in sdv_one_core_test() localVariable
87 let runtime = RuntimeBuilder::new_multi_thread() in sdv_two_core_test() localVariable
102 let runtime = RuntimeBuilder::new_multi_thread() in sdv_three_core_test() localVariable
116 let runtime = RuntimeBuilder::new_multi_thread() in sdv_four_core_test() localVariable
129 let runtime = RuntimeBuilder::new_multi_thread() in sdv_eight_core_test() localVariable
142 let runtime = RuntimeBuilder::new_multi_thread() in sdv_max_core_test() localVariable
154 let runtime = RuntimeBuilder::new_multi_thread() in sdv_complex_task_test() localVariable
|
| D | async_pool.rs | 99 let runtime = RuntimeBuilder::new_multi_thread() in sdv_async_pool_001() localVariable
159 let runtime = RuntimeBuilder::new_multi_thread() in sdv_async_pool_002() localVariable
219 let runtime = RuntimeBuilder::new_multi_thread() in sdv_async_pool_003() localVariable
279 let runtime = RuntimeBuilder::new_multi_thread() in sdv_async_pool_004() localVariable
339 let runtime = RuntimeBuilder::new_multi_thread() in sdv_async_pool_005() localVariable
399 let runtime = RuntimeBuilder::new_multi_thread() in sdv_async_pool_006() localVariable
459 let runtime = RuntimeBuilder::new_multi_thread() in sdv_async_pool_007() localVariable
519 let runtime = RuntimeBuilder::new_multi_thread() in sdv_async_pool_008() localVariable
|
| D | builder.rs | 37 let runtime = RuntimeBuilder::new_multi_thread() in sdv_set_builder_after_start() localVariable
66 let runtime = RuntimeBuilder::new_multi_thread() in sdv_set_builder_before_stop() localVariable
|
| D | tcp_test.rs | 105 let runtime = RuntimeBuilder::new_multi_thread().build().unwrap(); in sdv_tcp_multi_runtime() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| D | ylong_tokio_tcp_perf.rs | 35 let runtime = RuntimeBuilder::new_multi_thread().build().unwrap(); in ylong_create_client() localVariable
69 let runtime = tokio::runtime::Builder::new_multi_thread() in tokio_create_client() localVariable
106 let runtime = RuntimeBuilder::new_multi_thread().build().unwrap(); in main() localVariable
148 let runtime = tokio::runtime::Builder::new_multi_thread() in main() localVariable
|
| D | ylong_runtime_tcp_server_perf.rs | 24 let runtime = RuntimeBuilder::new_multi_thread().build().unwrap(); in main() localVariable
|
| D | ylong_tokio_spawn.rs | 70 let runtime = tokio::runtime::Runtime::new().unwrap(); in tokio_spawn() localVariable
|
| D | ylong_runtime_async_benchmark.rs | 54 let runtime = RuntimeBuilder::new_multi_thread() in main() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| D | ylong_tokio_async_file.rs | 34 let runtime = $runtime(); localVariable
58 let runtime = $runtime(); localVariable
85 let runtime = $runtime(); localVariable
|
| D | ylong_tokio_multi_threaded.rs | 54 let runtime = $runtime(); localVariable
103 let runtime = Arc::new(ylong_runtime()); in chained_spawn() localVariable
146 let runtime = tokio_runtime(); in chained_spawn() localVariable
|
| D | ylong_tokio_udp.rs | 62 let runtime = tokio_runtime(); in tokio_udp_connect() localVariable
131 let runtime = tokio_runtime(); in tokio_udp_send_recv() localVariable
213 let runtime = tokio_runtime(); in tokio_udp_send_to_recv_from() localVariable
|
| D | ylong_tokio_schedule.rs | 25 let runtime = $runtime; localVariable
|
| D | ylong_tokio_mutex.rs | 33 let runtime = $runtime; localVariable
|
| D | ylong_tokio_tcp.rs | 56 let runtime = $runtime; localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| D | ylong_tokio_schedule.rs | 48 let runtime = tokio::runtime::Builder::new_multi_thread() in tokio_schedule_task() localVariable
79 let runtime = tokio::runtime::Builder::new_multi_thread() in tokio_schedule_fibbo_task() localVariable
|
| D | ylong_runtime_memory.rs | 51 let runtime = $runtime(); localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/metrics/ |
| D | mod.rs | 14 mod runtime; module
|
| D | runtime.rs | 27 runtime: &'a Runtime, field
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
| D | async_utils.rs | 60 let runtime = init_test_work_runtime($thread_num); localVariable
149 let runtime = init_test_work_runtime($thread_num); localVariable
|
| D | sync_utils.rs | 60 let runtime = init_test_work_runtime($thread_num); localVariable
149 let runtime = init_test_work_runtime($thread_num); localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/builder/ |
| D | mod.rs | 266 let runtime = RuntimeBuilder::new_current_thread().build().unwrap(); in ut_thread_pool_builder_current_thread() localVariable
277 let runtime = RuntimeBuilder::new_current_thread().build().unwrap(); in ut_thread_pool_builder_current_thread() localVariable
284 let runtime = RuntimeBuilder::new_current_thread().build().unwrap(); in ut_thread_pool_builder_current_thread() localVariable
286 let runtime = RuntimeBuilder::new_current_thread().build().unwrap(); in ut_thread_pool_builder_current_thread() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | mod.rs | 111 let runtime = match initialize_async_spawner(global_builder.as_ref().unwrap()) { in global_default_async() localVariable
118 let runtime = match initialize_ffrt_spawner(global_builder.as_ref().unwrap()) { in global_default_async() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/ |
| D | core.rs | 36 let runtime = global_default_async(); in core() localVariable
|