| /external/rust/android-crates-io/crates/tokio/src/runtime/tests/ |
| D | loom_blocking.rs | 15 crate::task::spawn_blocking(move || { in blocking_shutdown()
34 runtime::spawn_blocking(|| {}); in spawn_mandatory_blocking_should_always_run()
87 let a = crate::task::spawn_blocking(|| {}); in spawn_blocking_when_paused()
88 let b = crate::task::spawn_blocking(|| {}); in spawn_blocking_when_paused()
|
| /external/rust/android-crates-io/crates/tokio/tests/ |
| D | task_blocking.rs | 21 task::spawn_blocking(|| { in basic_blocking()
42 task::spawn_blocking(|| { in block_in_blocking()
237 task::spawn_blocking(|| thread::sleep(Duration::from_millis(1))), in blocking_when_paused()
248 task::spawn_blocking(|| thread::sleep(Duration::from_millis(50))), in blocking_when_paused()
261 task::spawn_blocking(|| thread::sleep(Duration::from_millis(1))), in blocking_task_wakes_paused_runtime()
279 let a = task::spawn_blocking(|| { in unawaited_blocking_task_wakes_paused_runtime()
298 task::spawn_blocking(|| { in panicking_blocking_task_wakes_paused_runtime()
|
| D | task_builder.rs | 25 .spawn_blocking(|| "task executed") in spawn_blocking_with_name()
61 .spawn_blocking(|| "task executed") in spawn_blocking_without_name()
|
| D | rt_handle_block_on.rs | 163 use tokio::task::spawn_blocking;
168 .block_on(spawn_blocking(|| {
179 use tokio::task::spawn_blocking;
185 .block_on(spawn_blocking(|| {
196 use tokio::task::spawn_blocking;
200 let handle = spawn_blocking(|| {
|
| D | rt_unstable_metrics.rs | 33 let _ = rt.block_on(rt.spawn_blocking(move || {})); in num_blocking_threads()
38 let _ = rt.block_on(rt.spawn_blocking(move || {})); in num_blocking_threads()
46 let _ = rt.block_on(rt.spawn_blocking(move || {})); in num_idle_blocking_threads()
84 let h1 = rt.spawn_blocking(wait_until_ready.clone()); in blocking_queue_depth()
85 let h2 = rt.spawn_blocking(wait_until_ready); in blocking_queue_depth()
661 tokio::task::spawn_blocking(|| { in worker_overflow_count()
|
| D | rt_common.rs | 572 let inner = assert_ok!(tokio::task::spawn_blocking(|| {
588 let inner = assert_ok!(tokio::task::spawn_blocking(|| {
589 tokio::task::spawn_blocking(|| "hello")
604 assert_ok!(tokio::task::spawn_blocking(|| {
629 let peer = tokio::task::spawn_blocking(move || {
1055 task::spawn_blocking(move || {
1072 task::spawn_blocking(move || {
|
| /external/rust/android-crates-io/crates/tokio/src/fs/ |
| D | mod.rs | 301 use crate::blocking::spawn_blocking;
303 use mocks::spawn_blocking;
310 match spawn_blocking(f).await { in asyncify()
|
| D | read_dir.rs | 14 use super::mocks::spawn_blocking;
18 use crate::blocking::spawn_blocking;
115 self.0 = State::Pending(spawn_blocking(move || { in poll_next_entry()
|
| D | file.rs | 24 use super::mocks::{spawn_blocking, spawn_mandatory_blocking};
28 use crate::blocking::{spawn_blocking, spawn_mandatory_blocking};
401 inner.state = State::Busy(spawn_blocking(move || { in set_len()
606 inner.state = State::Busy(spawn_blocking(move || { in poll_read()
675 inner.state = State::Busy(spawn_blocking(move || { in start_seek()
|
| /external/crosvm/cros_async/src/sys/windows/ |
| D | tokio_source.rs | 132 .spawn_blocking(move || { in fsync()
151 .spawn_blocking(move || { in punch_hole()
172 .spawn_blocking(move || { in read_to_mem()
196 .spawn_blocking(move || { in read_to_vec()
228 .spawn_blocking(move || { in write_from_mem()
252 .spawn_blocking(move || { in write_from_vec()
271 .spawn_blocking(move || { in write_zeroes_at()
|
| /external/rust/android-crates-io/crates/tokio/src/task/ |
| D | blocking.rs | 202 pub fn spawn_blocking<F, R>(f: F) -> JoinHandle<R>
207 crate::runtime::spawn_blocking(f)
|
| D | join_set.rs | 240 pub fn spawn_blocking<F>(&mut self, f: F) -> AbortHandle in spawn_blocking() method
246 self.insert(crate::runtime::spawn_blocking(f)) in spawn_blocking()
261 self.insert(handle.spawn_blocking(f)) in spawn_blocking_on()
706 pub fn spawn_blocking<F>(self, f: F) -> std::io::Result<AbortHandle> in spawn_blocking() method
712 Ok(self.joinset.insert(self.builder.spawn_blocking(f)?)) in spawn_blocking()
|
| D | mod.rs | 328 pub use blocking::spawn_blocking;
|
| /external/crosvm/cros_async/src/sys/linux/ |
| D | tokio_source.rs | 214 .spawn_blocking(move || do_fdatasync(fd)) in fdatasync()
224 .spawn_blocking(move || do_fsync(fd)) in fsync()
252 .spawn_blocking(move || { in read_to_vec()
286 .spawn_blocking(move || { in read_to_mem()
304 .spawn_blocking(move || fallocate(&*fd, FallocateMode::PunchHole, file_offset, len)) in punch_hole()
345 .spawn_blocking(move || { in write_from_mem()
377 .spawn_blocking(move || { in write_from_vec()
392 .spawn_blocking(move || fallocate(&*fd, FallocateMode::ZeroRange, file_offset, len)) in write_zeroes_at()
|
| /external/rust/android-crates-io/crates/tokio-util/tests/ |
| D | io_sync_bridge.rs | 14 let res = tokio::task::spawn_blocking(move || { in test_reader_len()
36 let dest = tokio::task::spawn_blocking(move || -> Result<_, String> { in test_async_write_to_sync()
62 tokio::task::spawn_blocking(move || -> std::io::Result<_> { in test_shutdown()
|
| /external/rust/android-crates-io/crates/tokio/src/ |
| D | blocking.rs | 2 pub(crate) use crate::runtime::spawn_blocking;
18 pub(crate) fn spawn_blocking<F, R>(_f: F) -> JoinHandle<R>
|
| /external/crosvm/cros_async/src/ |
| D | executor.rs | 222 fn spawn_blocking<F, R>(&self, f: F) -> TaskHandle<R> in spawn_blocking() method
556 pub fn spawn_blocking<F, R>(&self, f: F) -> TaskHandle<R> in spawn_blocking() method
563 Executor::Fd(ex) => ex.spawn_blocking(f), in spawn_blocking()
565 Executor::Uring(ex) => ex.spawn_blocking(f), in spawn_blocking()
567 Executor::Handle(ex) => ex.spawn_blocking(f), in spawn_blocking()
569 Executor::Overlapped(ex) => ex.spawn_blocking(f), in spawn_blocking()
571 Executor::Tokio(ex) => ex.spawn_blocking(f), in spawn_blocking()
|
| D | tokio_executor.rs | 108 fn spawn_blocking<F, R>(&self, f: F) -> TaskHandle<R> in spawn_blocking() method
114 join_handle: Some(self.runtime.spawn_blocking(f)), in spawn_blocking()
|
| /external/rust/android-crates-io/crates/tokio/src/net/ |
| D | addr.rs | 169 use crate::blocking::spawn_blocking;
182 MaybeReady(sealed::State::Blocking(spawn_blocking(move || {
197 use crate::blocking::spawn_blocking;
219 MaybeReady(sealed::State::Blocking(spawn_blocking(move || {
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/local_runtime/ |
| D | runtime.rs | 189 pub fn spawn_blocking<F, R>(&self, func: F) -> JoinHandle<R> in spawn_blocking() method
194 self.handle.spawn_blocking(func) in spawn_blocking()
|
| /external/rust/android-crates-io/crates/tokio-util/src/task/ |
| D | task_tracker.rs | 441 pub fn spawn_blocking<F, T>(&self, task: F) -> JoinHandle<T> in spawn_blocking() method
448 tokio::task::spawn_blocking(move || { in spawn_blocking()
470 handle.spawn_blocking(move || { in spawn_blocking_on()
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/blocking/ |
| D | mod.rs | 7 pub(crate) use pool::{spawn_blocking, BlockingPool, Spawner};
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/ |
| D | runtime.rs | 275 pub fn spawn_blocking<F, R>(&self, func: F) -> JoinHandle<R> in spawn_blocking() method
280 self.handle.spawn_blocking(func) in spawn_blocking()
|
| D | mod.rs | 356 pub(crate) use blocking::spawn_blocking;
|
| /external/crosvm/base_tokio/src/ |
| D | tube.rs | 16 let blocking_task = tokio::task::spawn_blocking(move || { in recv_send()
|