• Home
  • Raw
  • Download

Lines Matching refs:spawn

45     let spawn = pool.spawner();  in run_until_ignores_spawned()  localVariable
46 spawn.spawn_local_obj(Box::pin(pending()).into()).unwrap(); in run_until_ignores_spawned()
54 let spawn = pool.spawner(); in run_until_executes_spawned() localVariable
55 spawn.spawn_local_obj(Box::pin(lazy(move |_| { in run_until_executes_spawned()
74 let spawn = pool.spawner(); in run_executes_spawned() localVariable
77 spawn.spawn_local_obj(Box::pin(lazy(move |_| { in run_executes_spawned()
96 let spawn = pool.spawner(); in run_spawn_many() localVariable
100 spawn.spawn_local_obj(Box::pin(lazy(move |_| { in run_spawn_many()
123 let spawn = pool.spawner(); in try_run_one_executes_one_ready() localVariable
126 spawn.spawn_local_obj(Box::pin(pending()).into()).unwrap(); in try_run_one_executes_one_ready()
129 spawn.spawn_local_obj(Box::pin(lazy(move |_| { in try_run_one_executes_one_ready()
133 spawn.spawn_local_obj(Box::pin(pending()).into()).unwrap(); in try_run_one_executes_one_ready()
151 let spawn = pool.spawner(); in try_run_one_returns_on_no_progress() localVariable
157 spawn.spawn_local_obj(Box::pin(poll_fn(move |ctx| { in try_run_one_returns_on_no_progress()
183 let spawn = pool.spawner(); in try_run_one_runs_sub_futures() localVariable
186 let inner_spawner = spawn.clone(); in try_run_one_runs_sub_futures()
188 spawn.spawn_local_obj(Box::pin(poll_fn(move |_| { in try_run_one_runs_sub_futures()
213 let spawn = pool.spawner(); in run_until_stalled_returns_multiple_times() localVariable
217 spawn.spawn_local_obj(Box::pin(lazy(move |_|{ cnt1.set(cnt1.get() + 1) })).into()).unwrap(); in run_until_stalled_returns_multiple_times()
222 spawn.spawn_local_obj(Box::pin(lazy(move |_|{ cnt2.set(cnt2.get() + 1) })).into()).unwrap(); in run_until_stalled_returns_multiple_times()
230 let spawn = pool.spawner(); in run_until_stalled_runs_spawned_sub_futures() localVariable
233 let inner_spawner = spawn.clone(); in run_until_stalled_runs_spawned_sub_futures()
235 spawn.spawn_local_obj(Box::pin(poll_fn(move |_| { in run_until_stalled_runs_spawned_sub_futures()
258 let spawn = pool.spawner(); in run_until_stalled_executes_all_ready() localVariable
262 spawn.spawn_local_obj(Box::pin(pending()).into()).unwrap(); in run_until_stalled_executes_all_ready()
265 spawn.spawn_local_obj(Box::pin(lazy(move |_| { in run_until_stalled_executes_all_ready()
270 spawn.spawn_local_obj(Box::pin(pending()).into()).unwrap(); in run_until_stalled_executes_all_ready()
282 let spawn = pool.spawner(); in nesting_run() localVariable
284 spawn.spawn_obj(Box::pin(lazy(|_| { in nesting_run()
296 let spawn = pool.spawner(); in nesting_run_run_until_stalled() localVariable
298 spawn.spawn_obj(Box::pin(lazy(|_| { in nesting_run_run_until_stalled()
343 let spawn = pool.spawner(); in tasks_are_scheduled_fairly() localVariable
345 spawn.spawn_local_obj(Box::pin(Spin { in tasks_are_scheduled_fairly()
350 spawn.spawn_local_obj(Box::pin(Spin { in tasks_are_scheduled_fairly()
374 thread::spawn(move || { in park_unpark_independence()