Lines Matching refs:spawn
237 let t = thread::spawn(move || { in smoke_threads()
270 let t = thread::spawn(move || { in port_gone_concurrent()
281 let t = thread::spawn(move || { in port_gone_concurrent_shared()
307 let t = thread::spawn(move || { in chan_gone_concurrent()
318 let t = thread::spawn(move || { in stress()
335 let t = thread::spawn(move || { in stress_shared()
348 let t = thread::spawn(move || { in stress_shared()
366 let t1 = thread::spawn(move || { in send_from_outside_runtime()
373 let t2 = thread::spawn(move || { in send_from_outside_runtime()
385 let t = thread::spawn(move || { in recv_from_outside_runtime()
400 let t1 = thread::spawn(move || { in no_runtime()
404 let t2 = thread::spawn(move || { in no_runtime()
501 let t = thread::spawn(move || { in oneshot_multi_task_recv_then_send()
512 let t = thread::spawn(move || { in oneshot_multi_task_recv_then_close()
515 thread::spawn(move || { in oneshot_multi_task_recv_then_close()
529 let t = thread::spawn(move || { in oneshot_multi_thread_close_stress()
546 let t = thread::spawn(move || { in oneshot_multi_thread_send_close_stress()
550 thread::spawn(move || { in oneshot_multi_thread_send_close_stress()
567 let t = thread::spawn(move || { in oneshot_multi_thread_recv_close_stress()
568 thread::spawn(move || { in oneshot_multi_thread_recv_close_stress()
575 let t2 = thread::spawn(move || { in oneshot_multi_thread_recv_close_stress()
576 let t = thread::spawn(move || { in oneshot_multi_thread_recv_close_stress()
594 let t = thread::spawn(move || { in oneshot_multi_thread_send_recv_stress()
624 Some(thread::spawn(move || { in stream_send_recv_stress()
635 Some(thread::spawn(move || { in stream_send_recv_stress()
665 let t = thread::spawn(move || { in stress_recv_timeout_two_threads()
709 let t = thread::spawn(move || { in stress_recv_timeout_shared()
755 let t = thread::spawn(move || { in shared_recv_timeout()
783 let t = thread::spawn(move || { in shared_chan_stress()
802 let t = thread::spawn(move || { in test_nested_recv_iter()
823 let t = thread::spawn(move || { in test_recv_iter_break()
850 let t = thread::spawn(move || { in test_recv_try_iter()
903 let t = thread::spawn(move || { in try_recv_states()
929 let t = thread::spawn(move || { in destroy_upgraded_shared_port_when_sender_still_active()
1009 let t = thread::spawn(move || { in smoke_threads()
1035 let t = thread::spawn(move || { in port_gone_concurrent()
1046 let t = thread::spawn(move || { in port_gone_concurrent_shared()
1072 let t = thread::spawn(move || { in chan_gone_concurrent()
1083 let t = thread::spawn(move || { in stress()
1098 let t = thread::spawn(move || { in stress_recv_timeout_two_threads()
1127 let t = thread::spawn(move || { in stress_recv_timeout_shared()
1149 let t = thread::spawn(move || { in stress_recv_timeout_shared()
1173 let t = thread::spawn(move || { in stress_shared()
1187 let t = thread::spawn(move || { in stress_shared()
1306 let t = thread::spawn(move || { in oneshot_multi_task_recv_then_send()
1317 let t = thread::spawn(move || { in oneshot_multi_task_recv_then_close()
1320 thread::spawn(move || { in oneshot_multi_task_recv_then_close()
1334 let t = thread::spawn(move || { in oneshot_multi_thread_close_stress()
1351 let t = thread::spawn(move || { in oneshot_multi_thread_send_close_stress()
1355 thread::spawn(move || { in oneshot_multi_thread_send_close_stress()
1372 let t = thread::spawn(move || { in oneshot_multi_thread_recv_close_stress()
1373 thread::spawn(move || { in oneshot_multi_thread_recv_close_stress()
1380 let t2 = thread::spawn(move || { in oneshot_multi_thread_recv_close_stress()
1381 thread::spawn(move || { in oneshot_multi_thread_recv_close_stress()
1398 let t = thread::spawn(move || { in oneshot_multi_thread_send_recv_stress()
1428 Some(thread::spawn(move || { in stream_send_recv_stress()
1439 Some(thread::spawn(move || { in stream_send_recv_stress()
1469 let t = thread::spawn(move || { in shared_chan_stress()
1488 let t = thread::spawn(move || { in test_nested_recv_iter()
1509 let t = thread::spawn(move || { in test_recv_iter_break()
1535 let t = thread::spawn(move || { in try_recv_states()
1561 let t = thread::spawn(move || { in destroy_upgraded_shared_port_when_sender_still_active()
1584 let t = thread::spawn(move || { in send1()
1594 let t = thread::spawn(move || { in send2()
1605 let t = thread::spawn(move || { in send3()
1618 let t = thread::spawn(move || { in send4()
1622 let t2 = thread::spawn(move || { in send4()
1660 let _t = thread::spawn(move || { in issue_15761()
1741 let t = thread::spawn(move || { in unblocks()
1770 let t = thread::spawn(move || { in both_ready()
1800 let t = thread::spawn(move || { in stress()
1828 let t = thread::spawn(move || { in cloning()
1852 let t = thread::spawn(move || { in cloning2()
1874 let t = thread::spawn(move || { in cloning3()
1985 let t = thread::spawn(move || { in oneshot_data_waiting()
2008 let t = thread::spawn(move || { in stream_data_waiting()
2030 let t = thread::spawn(move || { in shared_data_waiting()
2057 let t = thread::spawn(move || { in sync2()
2073 let t = thread::spawn(move || { in sync3()
2076 let t2 = thread::spawn(move || { in sync3()