Searched refs:handlers (Results 1 - 16 of 16) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A D	ylong_tokio_rwlock.rs	54 let mut handlers = Vec::with_capacity(6); in tokio_rwlock_read() variables 57 handlers.push(rt.spawn(tokio_rwlock_task(lock.clone()))); in tokio_rwlock_read() 60 for handler in handlers { in tokio_rwlock_read() 79 let mut handlers = Vec::with_capacity(6); in ylong_rwlock_read() variables 82 handlers.push(ylong_runtime::spawn(ylong_rwlock_task(lock.clone()))); in ylong_rwlock_read() 85 for handler in handlers { in ylong_rwlock_read() 103 let mut handlers = Vec::with_capacity(6); in tokio_rwlock_write() variables 106 handlers.push(rt.spawn(tokio_rwlock_write_task(lock.clone()))); in tokio_rwlock_write() 109 for handler in handlers { in tokio_rwlock_write() 128 let mut handlers in ylong_rwlock_write() variables 154 let mut handlers = Vec::with_capacity(12); tokio_rwlock_write_read() variables 186 let mut handlers = Vec::with_capacity(12); ylong_rwlock_write_read() variables [all...]
H A D	ylong_tokio_spawn_blocking.rs	30 let mut handlers = Vec::with_capacity($num); variables 32 handlers.push(runtime.spawn_blocking(|| { 37 for handler in handlers { 51 let mut handlers = Vec::with_capacity($num); variables 53 handlers.push(ylong_runtime::spawn_blocking(|| { 58 for handler in handlers {
H A D	ylong_tokio_udp.rs	88 let mut handlers = Vec::new(); in ylong_udp_send_recv() variables 98 handlers.push(ylong_runtime::spawn(async move { in ylong_udp_send_recv() 115 for handler in handlers { in ylong_udp_send_recv() 135 let mut handlers = Vec::new(); in tokio_udp_send_recv() variables 139 handlers.push(runtime.spawn(async move { in tokio_udp_send_recv() 156 for handler in handlers { in tokio_udp_send_recv() 175 let mut handlers = Vec::new(); in ylong_udp_send_to_recv_from() variables 185 handlers.push(ylong_runtime::spawn(async move { in ylong_udp_send_to_recv_from() 199 for handler in handlers { in ylong_udp_send_to_recv_from() 218 let mut handlers in tokio_udp_send_to_recv_from() variables [all...]
H A D	ylong_tokio_bounded_mpsc.rs	31 let mut handlers = vec![]; variables 38 handlers.push(handle); 47 handlers.push(handle); 50 for handle in handlers { 65 let mut handlers = vec![]; variables 72 handlers.push(handle); 81 handlers.push(handle); 84 for handle in handlers {
H A D	ylong_tokio_task_creation.rs	29 let mut handlers = Vec::new(); variables 31 handlers.push(runtime.spawn(async move { 1 })); 45 let mut handlers = Vec::new(); variables 47 handlers.push(ylong_runtime::spawn(async move { 1 })); 62 let mut handlers = Vec::new(); variables 64 handlers.push(tokio::spawn(async move { 1 })); 81 let mut handlers = Vec::new(); variables 83 handlers.push(ylong_runtime::spawn(async move { 1 }));
H A D	ylong_tokio_unbounded_mpsc.rs	31 let mut handlers = vec![]; variables 38 handlers.push(handle); 47 handlers.push(handle); 50 for handle in handlers { 65 let mut handlers = vec![]; variables 72 handlers.push(handle); 81 handlers.push(handle); 84 for handle in handlers {
H A D	ylong_tokio_process.rs	29 let mut handlers = Vec::new(); variables 31 handlers.push(runtime.spawn(async { 41 for handler in handlers { 54 let mut handlers = Vec::new(); variables 56 handlers.push(ylong_runtime::spawn(async { 66 for handler in handlers {
H A D	ylong_tokio_schedule.rs	27 let mut handlers = Vec::with_capacity($num); variables 29 handlers.push(runtime.spawn(async move { 35 for handler in handlers { 49 let mut handlers = Vec::with_capacity($num); variables 51 handlers.push(ylong_runtime::spawn(async move { 57 for handler in handlers {
H A D	ylong_tokio_mutex.rs	37 let mut handlers = Vec::with_capacity($num); variables 40 handlers.push(runtime.spawn(async move { 48 for handler in handlers { 67 let mut handlers = Vec::with_capacity($num); variables 70 handlers.push(ylong_runtime::spawn(async move { 78 for handler in handlers {
H A D	ylong_tokio_tcp.rs	60 let mut handlers = Vec::new(); variables 63 handlers.push(runtime.spawn($server(addr.clone()))); 64 handlers.push(runtime.spawn($client(addr.clone()))); 66 for handler in handlers { 112 let mut handlers = Vec::new(); variables 117 handlers.push(ylong_runtime::spawn($server(addr))); 118 handlers.push(ylong_runtime::spawn($client(addr))); 120 for handler in handlers {
H A D	ylong_tokio_uds.rs	59 let mut handlers = Vec::new(); variables 62 handlers.push(runtime.spawn($server(addr.clone()))); 63 handlers.push(runtime.spawn($client(addr.clone()))); 65 for handler in handlers { 113 let mut handlers = Vec::new(); variables 116 handlers.push(ylong_runtime::spawn($server(addr.clone()))); 117 handlers.push(ylong_runtime::spawn($client(addr.clone()))); 119 for handler in handlers {
H A D	ylong_tokio_signal.rs	35 let mut handlers = Vec::with_capacity($num); variables 38 handlers.push(runtime.spawn(async move { 46 for handler in handlers { 84 let mut handlers = Vec::with_capacity($num); variables 87 handlers.push(runtime.spawn(async move { 95 for handler in handlers {
H A D	sync_benchmarks.rs	37 let handlers: Vec<[u8; TASK_NUM]> = black_box(Vec::with_capacity(TASK_NUM)); in single_thread_run_1000_fibbo() 42 assert_eq!(handlers.len(), 0); in single_thread_run_1000_fibbo()
/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A D	ylong_tokio_schedule.rs	35 let mut handlers = Vec::with_capacity(num); in ylong_schedule_task() variables 37 handlers.push(ylong_runtime::spawn(async move { in ylong_schedule_task() 42 for handler in handlers { in ylong_schedule_task() 52 let mut handlers = Vec::with_capacity(num); in tokio_schedule_task() variables 54 handlers.push(runtime.spawn(async move { in tokio_schedule_task() 59 for handler in handlers { in tokio_schedule_task() 65 let mut handlers = Vec::with_capacity(num); in ylong_schedule_fibbo_task() variables 67 handlers.push(ylong_runtime::spawn(async move { in ylong_schedule_fibbo_task() 73 for handler in handlers { in ylong_schedule_fibbo_task() 83 let mut handlers in tokio_schedule_fibbo_task() variables [all...]
H A D	ylong_timer_latency.rs	19 let mut handlers = vec![]; in main() variables 30 handlers.push(handle); in main() 33 for handler in handlers { in main() 41 let mut handlers = vec![]; in main() variables 52 handlers.push(handle); in main() 55 for handler in handlers { in main()
H A D	ylong_runtime_tcp.rs	56 let mut handlers = Vec::new(); in ylong_tcp_send_recv() variables 61 handlers.push(ylong_runtime::spawn(ylong_tcp_server(addr))); in ylong_tcp_send_recv() 62 handlers.push(ylong_runtime::spawn(ylong_tcp_client(addr))); in ylong_tcp_send_recv() 64 for handler in handlers { in ylong_tcp_send_recv()

Completed in 7 milliseconds

Indexes created Thu Nov 07 10:32:03 CST 2024