| /external/rust/android-crates-io/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
315 impl<T> Unpin for JoinHandle<T> {} implementation
317 impl<T> Future for JoinHandle<T> { implementation
351 impl<T> Drop for JoinHandle<T> { implementation
361 impl<T> fmt::Debug for JoinHandle<T> implementation
|
| /external/trusty/lk/lib/rust_support/ |
| D | thread.rs | 137 pub struct JoinHandle { struct
141 impl JoinHandle { impl
191 pub fn spawn<F>(self, f: F) -> Result<JoinHandle, i32> in spawn()
240 pub fn spawn<F>(f: F) -> Result<JoinHandle, i32> in spawn()
|
| /external/rust/android-crates-io/crates/tokio/src/fs/ |
| D | mocks.rs | 90 pub(super) struct JoinHandle<T> { struct
94 pub(super) fn spawn_blocking<F, R>(f: F) -> JoinHandle<R> in spawn_blocking() argument
124 impl<T> Future for JoinHandle<T> { implementation
|
| /external/crosvm/vendor/generic/anti_tamper/src/ |
| D | lib.rs | 42 ) -> thread::JoinHandle<()> { in spawn_dedicated_anti_tamper_thread()
|
| /external/crosvm/src/crosvm/sys/linux/ |
| D | vcpu.rs | 652 vcpu_handles: &[(JoinHandle<()>, mpsc::Sender<vm_control::VcpuControl>)], in kick_all_vcpus()
670 vcpu_handle: &Option<&(JoinHandle<()>, mpsc::Sender<vm_control::VcpuControl>)>, in kick_vcpu()
|
| /external/rust/android-crates-io/crates/tracing/tests/ |
| D | missed_register_callsite.rs | 79 fn subscriber_thread(idx: usize, register_sleep_micros: u64) -> JoinHandle<()> { in subscriber_thread()
|
| /external/crosvm/src/crosvm/plugin/ |
| D | process.rs | 507 fn handle_pause_vcpus(&self, vcpu_handles: &[JoinHandle<()>], cpu_mask: u64, user_data: u64) { in handle_pause_vcpus()
558 vcpu_handles: &[JoinHandle<()>], in handle_socket()
|
| D | mod.rs | 263 vcpu_handles: &mut Vec<thread::JoinHandle<()>>, in run_vcpus()
|
| /external/rust/android-crates-io/crates/tracing-core/tests/ |
| D | missed_register_callsite.rs | 66 fn subscriber_thread(idx: usize, register_sleep_micros: u64) -> JoinHandle<()> { in subscriber_thread()
|
| /external/rust/android-crates-io/crates/virtio-drivers-and-devices/src/device/sound/ |
| D | fake.rs | 89 pub fn spawn(&self) -> JoinHandle<()> { in spawn()
|
| /external/rust/android-crates-io/crates/virtio-drivers/src/device/sound/ |
| D | fake.rs | 89 pub fn spawn(&self) -> JoinHandle<()> { in spawn()
|
| /external/crosvm/devices/src/ |
| D | lib.rs | 217 ) -> std::io::Result<std::thread::JoinHandle<()>> { in create_devices_worker_thread()
|
| /external/rust/android-crates-io/crates/crossbeam-channel/tests/ |
| D | mpsc.rs | 625 fn send(tx: Sender<Box<i32>>, i: i32) -> Option<JoinHandle<()>> { in stream_send_recv_stress()
636 fn recv(rx: Receiver<Box<i32>>, i: i32) -> Option<JoinHandle<()>> { in stream_send_recv_stress()
1446 fn send(tx: SyncSender<Box<i32>>, i: i32) -> Option<JoinHandle<()>> { in stream_send_recv_stress()
1457 fn recv(rx: Receiver<Box<i32>>, i: i32) -> Option<JoinHandle<()>> { in stream_send_recv_stress()
|
| /external/crosvm/devices/src/utils/ |
| D | event_loop.rs | 66 ) -> Result<(EventLoop, thread::JoinHandle<()>)> { in start()
|
| /external/rust/android-crates-io/crates/parking_lot/src/ |
| D | condvar.rs | 706 ) -> JoinHandle<()> { in spawn_wait_while_notifier()
1052 ) -> thread::JoinHandle<()> { in consumer_thread()
1086 ) -> thread::JoinHandle<()> { in producer_thread()
|
| /external/rust/android-crates-io/crates/vmm-sys-util/src/linux/ |
| D | signal.rs | 449 unsafe impl<T> Killable for JoinHandle<T> { implementation
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/tests/ |
| D | task_combinations.rs | 63 JoinHandle, enumerator
|
| /external/crosvm/base/src/sys/linux/ |
| D | signal.rs | 564 unsafe impl<T> Killable for JoinHandle<T> { implementation
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/blocking/ |
| D | pool.rs | 457 ) -> io::Result<thread::JoinHandle<()>> { in spawn_thread()
|
| /external/crosvm/base/src/sys/windows/ |
| D | named_pipes.rs | 1533 fn send_receive_msgs(pipe: MultiPartMessagePipe, msg_count: u32) -> JoinHandle<()> { in send_receive_msgs()
|