Lines Matching full:async
31 rt.block_on(async { in num_idle_blocking_threads()
42 rt.block_on(async { in num_idle_blocking_threads()
87 handle.spawn(async { in remote_schedule_count()
101 handle.spawn(async { in remote_schedule_count()
117 rt.block_on(async { in worker_park_count()
125 rt.block_on(async { in worker_park_count()
140 rt.block_on(async { in worker_noop_count()
148 rt.block_on(async { in worker_noop_count()
166 rt.block_on(async { in worker_steal_count()
170 tokio::spawn(async move { in worker_steal_count()
172 tokio::spawn(async move { in worker_steal_count()
178 tokio::spawn(async {}); in worker_steal_count()
202 rt.block_on(async { in worker_poll_count()
204 tokio::spawn(async {}).await.unwrap(); in worker_poll_count()
212 rt.block_on(async { in worker_poll_count()
214 tokio::spawn(async {}).await.unwrap(); in worker_poll_count()
235 rt.block_on(async { in worker_total_busy_duration()
237 tokio::spawn(async { in worker_total_busy_duration()
252 rt.block_on(async { in worker_total_busy_duration()
254 tokio::spawn(async { in worker_total_busy_duration()
273 rt.block_on(async { in worker_local_schedule_count()
274 tokio::spawn(async {}).await.unwrap(); in worker_local_schedule_count()
283 rt.block_on(async { in worker_local_schedule_count()
285 tokio::spawn(async { in worker_local_schedule_count()
286 tokio::spawn(async {}).await.unwrap(); in worker_local_schedule_count()
306 rt.block_on(async { in worker_overflow_count()
308 tokio::spawn(async { in worker_overflow_count()
314 tokio::spawn(async move { in worker_overflow_count()
320 tokio::spawn(async {}); in worker_overflow_count()
326 tokio::spawn(async {}); in worker_overflow_count()
352 handle.spawn(async {}); in injection_queue_depth()
367 rt.spawn(async move { rx1.recv().unwrap() }); in injection_queue_depth()
368 rt.spawn(async move { rx2.recv().unwrap() }); in injection_queue_depth()
371 handle.spawn(async {}); in injection_queue_depth()
390 rt.block_on(async { in worker_local_queue_depth()
392 tokio::spawn(async {}); in worker_local_queue_depth()
400 rt.block_on(async move { in worker_local_queue_depth()
402 tokio::spawn(async move { in worker_local_queue_depth()
408 tokio::spawn(async move { in worker_local_queue_depth()
414 tokio::spawn(async {}); in worker_local_queue_depth()
420 tokio::spawn(async {}); in worker_local_queue_depth()
445 let stream = rt.block_on(async move { stream.await.unwrap() }); in io_driver_fd_count()
463 let _stream = rt.block_on(async move { stream.await.unwrap() }); in io_driver_ready_count()