| /external/rust/crates/tokio/src/runtime/ |
| D | spawner.rs | 24 if let Spawner::ThreadPool(spawner) = self { in shutdown()
25 spawner.shutdown(); in shutdown()
40 Spawner::Basic(spawner) => spawner.spawn(future),
42 Spawner::ThreadPool(spawner) => spawner.spawn(future),
|
| D | basic_scheduler.rs | 31 spawner: Spawner, field
45 spawner: Spawner, field
125 let spawner = Spawner { in new() localVariable
138 spawner: spawner.clone(), in new()
146 spawner, in new()
150 pub(crate) fn spawner(&self) -> &Spawner { in spawner() method
151 &self.spawner in spawner()
204 let waker = scheduler.spawner.waker_ref(); in block_on()
211 if scheduler.spawner.was_woken() || !polled { in block_on()
224 scheduler.spawner.pop().or_else(|| { in block_on()
[all …]
|
| D | builder.rs | 445 let spawner = Spawner::Basic(scheduler.spawner().clone()); in build_basic_runtime() localVariable
449 let blocking_spawner = blocking_pool.spawner().clone(); in build_basic_runtime()
454 spawner, in build_basic_runtime()
550 let spawner = Spawner::ThreadPool(scheduler.spawner().clone()); localVariable
554 let blocking_spawner = blocking_pool.spawner().clone();
558 spawner,
|
| D | handle.rs | 17 pub(super) spawner: Spawner, field
149 self.spawner.spawn(future) in spawn()
290 self.spawner.shutdown(); in shutdown()
|
| D | mod.rs | 203 mod spawner;
204 use self::spawner::Spawner;
|
| D | context.rs | 50 CONTEXT.with(|ctx| (*ctx.borrow()).as_ref().map(|ctx| ctx.spawner.clone()))
|
| /external/rust/crates/tokio/src/runtime/thread_pool/ |
| D | mod.rs | 23 spawner: Spawner, field
48 let spawner = Spawner { shared }; in new() localVariable
49 let thread_pool = ThreadPool { spawner }; in new()
58 pub(crate) fn spawner(&self) -> &Spawner { in spawner() method
59 &self.spawner in spawner()
83 self.spawner.shutdown(); in drop()
|
| /external/rust/crates/futures-executor/tests/ |
| D | local_pool.rs | 45 let spawn = pool.spawner(); in run_until_ignores_spawned()
54 let spawn = pool.spawner(); in run_until_executes_spawned()
74 let spawn = pool.spawner(); in run_executes_spawned()
75 let spawn2 = pool.spawner(); in run_executes_spawned()
96 let spawn = pool.spawner(); in run_spawn_many()
123 let spawn = pool.spawner(); in try_run_one_executes_one_ready()
151 let spawn = pool.spawner(); in try_run_one_returns_on_no_progress()
183 let spawn = pool.spawner(); in try_run_one_runs_sub_futures()
213 let spawn = pool.spawner(); in run_until_stalled_returns_multiple_times()
230 let spawn = pool.spawner(); in run_until_stalled_runs_spawned_sub_futures()
[all …]
|
| /external/rust/crates/tokio/src/runtime/blocking/ |
| D | pool.rs | 19 spawner: Spawner, field
109 spawner: Spawner { in new()
135 pub(crate) fn spawner(&self) -> &Spawner { in spawner() method
136 &self.spawner in spawner()
140 let mut shared = self.spawner.inner.shared.lock(); in shutdown()
151 self.spawner.inner.condvar.notify_all(); in shutdown()
|
| /external/crosvm/cros_async/src/sync/ |
| D | cv.rs | 551 async fn wait(mu: Rc<Mutex<()>>, cv: Rc<Condvar>, spawner: LocalSpawner) { in notify_one_single_thread_async()
558 spawner in notify_one_single_thread_async()
565 let spawner = ex.spawner(); in notify_one_single_thread_async() localVariable
570 spawner in notify_one_single_thread_async()
571 .spawn_local(wait(mu, cv, spawner.clone())) in notify_one_single_thread_async()
846 async fn watcher(mu: Rc<Mutex<usize>>, cv: Rc<Condvar>, spawner: LocalSpawner) { in notify_all_single_thread_async()
850 spawner in notify_all_single_thread_async()
861 let spawner = ex.spawner(); in notify_all_single_thread_async() localVariable
867 spawner in notify_all_single_thread_async()
868 .spawn_local(watcher(mu.clone(), cv.clone(), spawner.clone())) in notify_all_single_thread_async()
|
| D | mu.rs | 958 let spawner = ex.spawner(); in async_smoke() localVariable
960 spawner in async_smoke()
963 spawner in async_smoke()
966 spawner in async_smoke()
969 spawner in async_smoke()
1112 let spawner = ex.spawner(); in single_thread_async() localVariable
1116 spawner in single_thread_async()
1296 let spawner = ex.spawner(); in rw_single_thread_async() localVariable
1298 spawner in rw_single_thread_async()
1303 spawner in rw_single_thread_async()
|
| /external/libchromeos-rs/src/sync/ |
| D | cv.rs | 587 async fn wait(mu: Rc<Mutex<()>>, cv: Rc<Condvar>, spawner: LocalSpawner) { in notify_one_single_thread_async()
594 spawner in notify_one_single_thread_async()
601 let spawner = ex.spawner(); in notify_one_single_thread_async() localVariable
606 spawner in notify_one_single_thread_async()
607 .spawn_local(wait(mu, cv, spawner.clone())) in notify_one_single_thread_async()
882 async fn watcher(mu: Rc<Mutex<usize>>, cv: Rc<Condvar>, spawner: LocalSpawner) { in notify_all_single_thread_async()
886 spawner in notify_all_single_thread_async()
897 let spawner = ex.spawner(); in notify_all_single_thread_async() localVariable
903 spawner in notify_all_single_thread_async()
904 .spawn_local(watcher(mu.clone(), cv.clone(), spawner.clone())) in notify_all_single_thread_async()
|
| D | mu.rs | 1081 let spawner = ex.spawner(); in async_smoke() localVariable
1083 spawner in async_smoke()
1086 spawner in async_smoke()
1089 spawner in async_smoke()
1092 spawner in async_smoke()
1235 let spawner = ex.spawner(); in single_thread_async() localVariable
1239 spawner in single_thread_async()
1417 let spawner = ex.spawner(); in rw_single_thread_async() localVariable
1419 spawner in rw_single_thread_async()
1424 spawner in rw_single_thread_async()
|
| /external/replicaisland/src/com/replica/replicaisland/ |
| D | LifetimeComponent.java | 172 public final void setTrackingSpawner(LaunchProjectileComponent spawner) { in setTrackingSpawner() argument
173 mTrackingSpawner = spawner; in setTrackingSpawner()
|
| /external/rust/crates/futures-executor/src/ |
| D | local_pool.rs | 129 pub fn spawner(&self) -> LocalSpawner { in spawner() method
|
| /external/rust/crates/futures/tests/ |
| D | shared.rs | 117 let spawn = &mut local_pool.spawner(); in peek()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/resources/ |
| D | ospd.txt.gz | |