| /external/rust/crates/tokio/src/runtime/task/ |
| D | join.rs | 144 pub struct JoinHandle<T> {
150 unsafe impl<T: Send> Send for JoinHandle<T> {} implementation
151 unsafe impl<T: Send> Sync for JoinHandle<T> {} implementation
153 impl<T> JoinHandle<T> { impl
154 pub(super) fn new(raw: RawTask) -> JoinHandle<T> { in new()
155 JoinHandle { in new()
200 impl<T> Unpin for JoinHandle<T> {} implementation
202 impl<T> Future for JoinHandle<T> { implementation
241 impl<T> Drop for JoinHandle<T> { implementation
253 impl<T> fmt::Debug for JoinHandle<T> implementation
|
| D | mod.rs | 14 pub use self::join::JoinHandle;
84 pub(crate) fn joinable<T, S>(task: T) -> (Notified<S>, JoinHandle<T::Output>)
96 let join = JoinHandle::new(raw);
104 pub(crate) unsafe fn joinable_local<T, S>(task: T) -> (Notified<S>, JoinHandle<T::Output>)
116 let join = JoinHandle::new(raw);
|
| /external/rust/crates/tokio/src/ |
| D | blocking.rs | 3 pub(crate) use crate::task::JoinHandle;
12 pub(crate) fn spawn_blocking<F, R>(_f: F) -> JoinHandle<R>
17 assert_send_sync::<JoinHandle<std::cell::Cell<()>>>();
22 pub(crate) struct JoinHandle<R> {
26 unsafe impl<T: Send> Send for JoinHandle<T> {}
27 unsafe impl<T: Send> Sync for JoinHandle<T> {}
29 impl<R> Future for JoinHandle<R> {
37 impl<T> fmt::Debug for JoinHandle<T>
|
| /external/rust/crates/tokio/src/runtime/blocking/ |
| D | pool.rs | 10 use crate::runtime::task::{self, JoinHandle};
66 last_exiting_thread: Option<thread::JoinHandle<()>>,
69 worker_threads: HashMap<usize, thread::JoinHandle<()>>,
80 pub(crate) fn spawn_blocking<F, R>(func: F) -> JoinHandle<R> in spawn_blocking()
163 let mut workers: Vec<(usize, thread::JoinHandle<()>)> = workers.into_iter().collect(); in shutdown()
245 ) -> thread::JoinHandle<()> { in spawn_thread() argument
|
| /external/rust/crates/async-task/ |
| D | CHANGELOG.md | 16 - Rename `JoinHandle` to `Task`.
32 - `JoinHandle` now only evaluates after the task's future has been dropped.
53 - Add `Task::waker` and `JoinHandle::waker`.
|
| /external/rust/crates/tokio/src/runtime/ |
| D | mod.rs | 220 use crate::task::JoinHandle;
372 pub fn spawn<F>(&self, future: F) -> JoinHandle<F::Output>
397 pub fn spawn_blocking<F, R>(&self, func: F) -> JoinHandle<R>
|
| D | spawner.rs | 3 use crate::task::JoinHandle;
33 pub(crate) fn spawn<F>(&self, future: F) -> JoinHandle<F::Output>
|
| D | handle.rs | 2 use crate::runtime::task::{self, JoinHandle};
142 pub fn spawn<F>(&self, future: F) -> JoinHandle<F::Output> in spawn()
172 pub fn spawn_blocking<F, R>(&self, func: F) -> JoinHandle<R> in spawn_blocking()
|
| D | basic_scheduler.rs | 5 use crate::runtime::task::{self, JoinHandle, Schedule, Task};
382 pub(crate) fn spawn<F>(&self, future: F) -> JoinHandle<F::Output> in spawn()
|
| /external/rust/crates/tokio/src/task/ |
| D | blocking.rs | 1 use crate::task::JoinHandle;
109 pub fn spawn_blocking<F, R>(f: F) -> JoinHandle<R>
|
| D | spawn.rs | 2 use crate::task::JoinHandle;
127 pub fn spawn<T>(task: T) -> JoinHandle<T::Output>
|
| D | local.rs | 2 use crate::runtime::task::{self, JoinHandle, Task};
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()
|
| D | mod.rs | 274 pub use crate::runtime::task::{JoinError, JoinHandle};
|
| /external/rust/crates/tokio/src/runtime/thread_pool/ |
| D | mod.rs | 15 use crate::runtime::task::{self, JoinHandle};
91 pub(crate) fn spawn<F>(&self, future: F) -> JoinHandle<F::Output> in spawn()
|
| /external/rust/crates/tokio/tests/ |
| D | io_copy_bidirectional.rs | 7 use tokio::task::JoinHandle;
40 F: FnMut(JoinHandle<io::Result<(u64, u64)>>, TcpStream, TcpStream) -> Fut, in symmetric()
|
| /external/adhd/sound_card_init/dsm/src/ |
| D | zero_player.rs | 8 use std::thread::JoinHandle;
94 thread: Option<JoinHandle<Result<()>>>,
|
| /external/rust/crates/grpcio/src/ |
| D | env.rs | 6 use std::thread::{Builder as ThreadBuilder, JoinHandle};
131 _handles: Vec<JoinHandle<()>>,
|
| /external/rust/crates/crossbeam-utils/src/ |
| D | thread.rs | 195 handles: SharedVec<SharedOption<thread::JoinHandle<()>>>,
478 handle: SharedOption<thread::JoinHandle<()>>,
|
| /external/rust/crates/tokio/src/io/ |
| D | mod.rs | 265 pub(crate) use crate::blocking::JoinHandle as Blocking;
|
| /external/rust/crates/tokio/src/fs/ |
| D | mod.rs | 126 pub(crate) use crate::blocking::JoinHandle as Blocking;
|
| /external/rust/crates/tokio/src/net/ |
| D | addr.rs | 259 use crate::blocking::JoinHandle;
273 Blocking(JoinHandle<io::Result<vec::IntoIter<SocketAddr>>>),
|
| /external/crosvm/devices/src/virtio/vhost/user/ |
| D | net.rs | 30 worker_thread: Option<thread::JoinHandle<Worker>>,
|
| D | block.rs | 34 worker_thread: Option<thread::JoinHandle<Worker>>,
|
| D | fs.rs | 28 worker_thread: Option<thread::JoinHandle<Worker>>,
|
| /external/crosvm/src/plugin/ |
| D | process.rs | 14 use std::thread::JoinHandle;
462 fn handle_pause_vcpus(&self, vcpu_handles: &[JoinHandle<()>], cpu_mask: u64, user_data: u64) { in handle_pause_vcpus() argument
513 vcpu_handles: &[JoinHandle<()>], in handle_socket() argument
|