| /external/rust/crates/tokio/src/runtime/task/ |
| D | join.rs | 162 unsafe impl<T: Send> Send for JoinHandle<T> {} implementation
163 unsafe impl<T: Send> Sync for JoinHandle<T> {} implementation
165 impl<T> UnwindSafe for JoinHandle<T> {} implementation
166 impl<T> RefUnwindSafe for JoinHandle<T> {} implementation
168 impl<T> JoinHandle<T> { impl
277 impl<T> Unpin for JoinHandle<T> {} implementation
279 impl<T> Future for JoinHandle<T> { implementation
312 impl<T> Drop for JoinHandle<T> { implementation
322 impl<T> fmt::Debug for JoinHandle<T> implementation
|
| /external/rust/crates/tokio/src/fs/ |
| D | mocks.rs | 89 pub(super) struct JoinHandle<T> { struct
93 pub(super) fn spawn_blocking<F, R>(f: F) -> JoinHandle<R> in spawn_blocking() argument
123 impl<T> Future for JoinHandle<T> { implementation
|
| /external/crosvm/anti_tamper/src/ |
| D | noop.rs | 24 pub fn spawn_dedicated_anti_tamper_thread(_tube_to_main_thread: Tube) -> thread::JoinHandle<()> { in spawn_dedicated_anti_tamper_thread()
|
| /external/crosvm/src/crosvm/sys/unix/ |
| D | vcpu.rs | 679 vcpu_handles: &[(JoinHandle<()>, mpsc::Sender<vm_control::VcpuControl>)], in kick_all_vcpus()
697 vcpu_handle: &Option<&(JoinHandle<()>, mpsc::Sender<vm_control::VcpuControl>)>, in kick_vcpu()
|
| /external/crosvm/src/crosvm/plugin/ |
| D | process.rs | 506 fn handle_pause_vcpus(&self, vcpu_handles: &[JoinHandle<()>], cpu_mask: u64, user_data: u64) { in handle_pause_vcpus()
557 vcpu_handles: &[JoinHandle<()>], in handle_socket()
|
| D | mod.rs | 263 vcpu_handles: &mut Vec<thread::JoinHandle<()>>, in run_vcpus()
|
| /external/crosvm/devices/src/utils/ |
| D | event_loop.rs | 66 ) -> Result<(EventLoop, thread::JoinHandle<()>)> { in start()
|
| /external/rust/crates/crossbeam-channel/tests/ |
| D | mpsc.rs | 627 fn send(tx: Sender<Box<i32>>, i: i32) -> Option<JoinHandle<()>> { in stream_send_recv_stress()
638 fn recv(rx: Receiver<Box<i32>>, i: i32) -> Option<JoinHandle<()>> { in stream_send_recv_stress()
1449 fn send(tx: SyncSender<Box<i32>>, i: i32) -> Option<JoinHandle<()>> { in stream_send_recv_stress()
1460 fn recv(rx: Receiver<Box<i32>>, i: i32) -> Option<JoinHandle<()>> { in stream_send_recv_stress()
|
| /external/rust/crates/parking_lot/src/ |
| D | condvar.rs | 704 ) -> JoinHandle<()> { in spawn_wait_while_notifier()
1053 ) -> thread::JoinHandle<()> { in consumer_thread()
1087 ) -> thread::JoinHandle<()> { in producer_thread()
|
| /external/crosvm/devices/src/ |
| D | lib.rs | 207 ) -> std::io::Result<std::thread::JoinHandle<()>> { in create_devices_worker_thread()
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | task_combinations.rs | 63 JoinHandle, enumerator
|
| /external/rust/crates/tokio/src/runtime/blocking/ |
| D | pool.rs | 457 ) -> std::io::Result<thread::JoinHandle<()>> { in spawn_thread()
|
| /external/crosvm/base/src/sys/unix/ |
| D | signal.rs | 571 unsafe impl<T> Killable for JoinHandle<T> { implementation
|