Searched defs:join_handle (Results 1 – 12 of 12) sorted by relevance
77 let join_handle = pool.spawn_pinned(|| async { in task_panic_propagates() localVariable89 let join_handle = pool.spawn_pinned(|| async { "test" }); in task_panic_propagates() localVariable101 let join_handle = pool.spawn_pinned(|| { in callback_panic_does_not_kill_worker() localVariable115 let join_handle = pool.spawn_pinned(|| async { "test" }); in callback_panic_does_not_kill_worker() localVariable131 let join_handle = pool.spawn_pinned(|| async move { in task_cancellation_propagates() localVariable
140 let join_handle = thread::spawn(move || { in handle_page_fault_zero_success() localVariable225 let join_handle = thread::spawn(move || { in handle_page_remove_success() localVariable246 let join_handle = thread::spawn(move || { in handle_page_remove_success() localVariable354 let join_handle = thread::spawn(move || { in move_to_staging_data_written_before_enabling() localVariable465 let join_handle = thread::spawn(move || { in move_to_staging_hugepage_chunks() localVariable606 let join_handle = thread::spawn(move || { in swap_out_success() localVariable671 let join_handle = thread::spawn(move || { in swap_out_handled_page() localVariable738 let join_handle = thread::spawn(move || { in swap_out_twice() localVariable772 let join_handle = thread::spawn(move || { in swap_out_twice() localVariable870 let join_handle = thread::spawn(move || { in swap_in_success() localVariable[all …]
14 let join_handle = tokio::spawn(async move { PanicsOnDrop }); in test_panics_do_not_propagate_when_dropping_join_handle() localVariable
57 let join_handle = tokio::spawn(async move { in acquire_many() localVariable
236 let join_handle = in spawn_pinned() localVariable256 let join_handle = match receiver.await { in spawn_pinned() localVariable
236 let join_handle = spawn(move || -> std::result::Result<(), ErrnoError> { in waitforinterrupt_success() localVariable
341 let join_handle = thread::Builder::new() in start() localVariable
618 let join_handle = vcpu_run_thread.run( in run_all_vcpus() localVariable
290 let join_handle = spawn_with_timeout(|| { in test_signaled_event() localVariable
98 let join_handle = { in main() localVariable
942 let join_handle = scope.spawn(|| { in handle_vmm_swap() localVariable1009 let join_handle = scope.spawn(|| { in handle_vmm_swap() localVariable
976 let join_handle = thread::spawn(move || { in test_co_init_called_once_per_thread() localVariable