| /external/rust/crates/tokio/tests/ |
| D | task_local_set.rs | 23 task::spawn_local(async {}).await.unwrap(); in local_basic_scheduler()
39 task::spawn_local(async { in local_threadpool()
57 local.spawn_local(async move { in localset_future_threadpool()
69 local.spawn_local(async move { in localset_future_timers()
73 local.spawn_local(async move { in localset_future_timers()
89 local.spawn_local(async move { in localset_future_drives_all_local_futs()
90 task::spawn_local(async { in localset_future_drives_all_local_futs()
97 local.spawn_local(async move { in localset_future_drives_all_local_futs()
120 let join = task::spawn_local(async move { in local_threadpool_timer()
147 let join = task::spawn_local(async move { in local_threadpool_blocking_in_place()
[all …]
|
| D | rt_common.rs | 945 task::spawn_local(async move {
975 task::spawn_local(async move {
|
| /external/rust/crates/async-task/ |
| D | CHANGELOG.md | 23 - Use `ThreadId` in `spawn_local` because OS-provided IDs can get recycled.
40 - Make `spawn_local` available only on unix and windows.
63 - Add `spawn_local` constructor.
|
| D | README.md | 24 A task is created using either `spawn()`, `spawn_local()`, or `spawn_unchecked()` which
|
| /external/crosvm/cros_async/src/ |
| D | executor.rs | 219 pub fn spawn_local<F>(&self, f: F) -> Task<F::Output> in spawn_local() method
225 Executor::Uring(ex) => ex.spawn_local(f), in spawn_local()
226 Executor::Fd(ex) => ex.spawn_local(f), in spawn_local()
|
| D | fd_executor.rs | 298 fn spawn_local<F>(self: &Arc<Self>, f: F) -> Task<F::Output> in spawn_local() method
310 let (runnable, task) = async_task::spawn_local(f, schedule); in spawn_local()
474 pub fn spawn_local<F>(&self, f: F) -> Task<F::Output> in spawn_local() method
479 self.raw.spawn_local(f) in spawn_local()
576 ex.spawn_local(write_value(tx)).detach(); in drop_before_completion()
577 ex.spawn_local(check_op(op)).detach(); in drop_before_completion()
|
| D | uring_executor.rs | 319 fn spawn_local<F>(self: &Arc<Self>, f: F) -> Task<F::Output> in spawn_local() method
331 let (runnable, task) = async_task::spawn_local(f, schedule); in spawn_local()
730 pub fn spawn_local<F>(&self, f: F) -> Task<F::Output> in spawn_local() method
735 self.raw.spawn_local(f) in spawn_local()
969 ex.spawn_local(cancel_io(read_task)).detach(); in canceled_before_completion()
1011 ex.spawn_local(check_op(op)).detach(); in drop_before_completion()
|
| D | poll_source.rs | 378 ex.spawn_local(owns_poll_source(source)).detach(); in memory_leak()
|
| /external/rust/crates/futures-util/src/task/ |
| D | spawn.rs | 124 fn spawn_local<Fut>(&self, future: Fut) -> Result<(), SpawnError> in spawn_local() method
160 self.spawn_local(future)?; in spawn_local_with_handle()
|
| /external/rust/crates/tokio/src/task/ |
| D | mod.rs | 290 pub use local::{spawn_local, LocalSet};
|
| D | local.rs | 295 pub fn spawn_local<F>(future: F) -> JoinHandle<F::Output>
379 pub fn spawn_local<F>(&self, future: F) -> JoinHandle<F::Output> in spawn_local() method
|
| /external/rust/crates/async-task/src/ |
| D | lib.rs | 88 pub use crate::runnable::spawn_local;
|
| D | runnable.rs | 87 pub fn spawn_local<F, S>(future: F, schedule: S) -> (Runnable, Task<F::Output>) in spawn_local() function
|
| /external/rust/crates/async-task/examples/ |
| D | spawn-local.rs | 22 let (runnable, task) = async_task::spawn_local(future, schedule); in spawn()
|
| /external/crosvm/cros_async/src/sync/ |
| D | cv.rs | 559 .spawn_local(notify(mu2, cv2)) in notify_one_single_thread_async()
571 .spawn_local(wait(mu, cv, spawner.clone())) in notify_one_single_thread_async()
851 .spawn_local(reset(mu.clone(), cv.clone())) 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 | 961 .spawn_local(lock(Rc::clone(&mu))) in async_smoke()
964 .spawn_local(read_lock(Rc::clone(&mu))) in async_smoke()
967 .spawn_local(double_read_lock(Rc::clone(&mu))) in async_smoke()
970 .spawn_local(lock(Rc::clone(&mu))) in async_smoke()
1117 .spawn_local(increment(Rc::clone(&mu))) in single_thread_async()
1299 .spawn_local(writer(Rc::clone(&mu))) in rw_single_thread_async()
1304 .spawn_local(reader(Rc::clone(&mu))) in rw_single_thread_async()
|
| /external/libchromeos-rs/src/sync/ |
| D | mu.rs | 1084 .spawn_local(lock(Rc::clone(&mu))) in async_smoke()
1087 .spawn_local(read_lock(Rc::clone(&mu))) in async_smoke()
1090 .spawn_local(double_read_lock(Rc::clone(&mu))) in async_smoke()
1093 .spawn_local(lock(Rc::clone(&mu))) in async_smoke()
1240 .spawn_local(increment(Rc::clone(&mu))) in single_thread_async()
1420 .spawn_local(writer(Rc::clone(&mu))) in rw_single_thread_async()
1425 .spawn_local(reader(Rc::clone(&mu))) in rw_single_thread_async()
|
| D | cv.rs | 595 .spawn_local(notify(mu2, cv2)) in notify_one_single_thread_async()
607 .spawn_local(wait(mu, cv, spawner.clone())) in notify_one_single_thread_async()
887 .spawn_local(reset(mu.clone(), cv.clone())) in notify_all_single_thread_async()
904 .spawn_local(watcher(mu.clone(), cv.clone(), spawner.clone())) in notify_all_single_thread_async()
|
| /external/crosvm/devices/src/virtio/ |
| D | block_async.rs | 332 ex.spawn_local(process_one_request_task( in handle_queue()
|
| /external/rust/crates/tokio/ |
| D | CHANGELOG.md | 173 - task: wake `LocalSet` on `spawn_local` ([#3369])
|