| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | spawn_blocking.rs | 29 handles.push(ylong_runtime::spawn_blocking(move || { in ffrt_spawn_blocking_test()
43 handles.push(task_builder.spawn_blocking(move || { in ffrt_spawn_blocking_test()
70 handles.push(runtime.spawn_blocking(move || { in test_spawn()
82 handles.push(ylong_runtime::spawn_blocking(move || { in test_spawn()
96 handles.push(task_builder.spawn_blocking(move || { in test_spawn()
|
| H A D | block_on.rs | 84 .spawn_blocking(|| { in sdv_block_on_nest_spawn_spawn_blocking()
114 .spawn_blocking(|| { in sdv_block_on_nest_spawn_and_spawn()
127 .spawn_blocking(|| { in sdv_block_on_nest_spawn_and_spawn()
162 .spawn_blocking(|| { in sdv_block_on_nest_spawn_nest_spawn()
|
| H A D | entry.rs | 36 mod spawn_blocking; module
|
| /ohos5.0/foundation/communication/ipc/interfaces/innerkits/rust/src/ipc_async/ |
| H A D | ipc_ylong.rs | 49 let handle = Runtime::spawn_blocking(spawn_this); in spawn()
76 fn spawn_blocking<T, R>(task: T) -> JoinHandle<R> in spawn_blocking() method
82 ylong_runtime::spawn_blocking(task) in spawn_blocking()
|
| H A D | mod.rs | 62 fn spawn_blocking<T, R>(task: T) -> JoinHandle<R> in spawn_blocking() method
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/ |
| H A D | spawn.rs | 47 pub(crate) fn spawn_blocking<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R>
60 pub(crate) fn spawn_blocking<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R> in spawn_blocking() function
67 rt.spawn_blocking(builder, task) in spawn_blocking()
|
| H A D | lib.rs | 45 pub use crate::task::{block_on, spawn, spawn_blocking};
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| H A D | builder.rs | 23 use crate::spawn::{spawn_async, spawn_blocking};
72 pub fn spawn_blocking<T, R>(&self, task: T) -> JoinHandle<R> in spawn_blocking() method
78 spawn_blocking(self, task) in spawn_blocking()
|
| H A D | mod.rs | 151 pub fn spawn_blocking<T, R>(task: T) -> JoinHandle<R> in spawn_blocking() function
157 TaskBuilder::new().spawn_blocking(task) in spawn_blocking()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| H A D | mod.rs | 31 use crate::spawn::spawn_blocking;
40 spawn_blocking(&TaskBuilder::new(), task) in async_op()
|
| H A D | async_file.rs | 27 use crate::spawn::spawn_blocking;
289 let (buf, res) = spawn_blocking(&TaskBuilder::new(), move || { in set_len()
399 FileState::Seeking(spawn_blocking(&TaskBuilder::new(), move || { in poll_seek()
457 FileState::Reading(spawn_blocking(&TaskBuilder::new(), move || { in poll_read()
516 FileState::Writing(spawn_blocking(&TaskBuilder::new(), move || { in poll_write()
|
| H A D | async_dir.rs | 28 use crate::spawn::spawn_blocking;
573 self.0 = State::Empty(spawn_blocking(&TaskBuilder::new(), move || { in poll_next()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_spawn_blocking.rs | 32 handlers.push(runtime.spawn_blocking(|| {
53 handlers.push(ylong_runtime::spawn_blocking(|| {
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/ |
| H A D | lib.rs | 87 task::{spawn_blocking, JoinHandle},
94 spawn_blocking,
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | stdin.rs | 20 use crate::spawn_blocking;
66 let handle = spawn_blocking(move || { in poll_read()
|
| H A D | stdio.rs | 132 let handle = spawn_blocking(move || {
167 self.state = State::Poll(spawn_blocking(move || {
|
| H A D | stderr.rs | 21 use crate::spawn_blocking;
|
| H A D | stdout.rs | 21 use crate::spawn_blocking;
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| H A D | ylong_runtime_short_block.rs | 21 let handle = ylong_runtime::spawn_blocking(|| { in main()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/docs/ |
| H A D | user_guide.md | 60 通过``spawn_blocking``生成任务
66 let join_handle = ylong_runtime::spawn_blocking(|| {});
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | addr.rs | 20 use crate::spawn_blocking;
153 let task = spawn_blocking(move || { in to_socket_addrs()
170 let task = spawn_blocking(move || { in to_socket_addrs()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | mod.rs | 237 pub fn spawn_blocking<T, R>(&self, task: T) -> JoinHandle<R> in spawn_blocking() method
242 crate::spawn::spawn_blocking(&TaskBuilder::new(), task) in spawn_blocking()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/ |
| H A D | resolver.rs | 97 let blocking = crate::runtime::spawn_blocking(move || { in resolve()
|
| /ohos5.0/base/msdp/device_status/rust/modules/scheduler/sys/src/ |
| H A D | lib.rs | 180 let handle = ylong_runtime::spawn_blocking(task); in post_blocking_task()
|
| /ohos5.0/foundation/communication/ipc/interfaces/innerkits/rust/src/remote/ |
| H A D | obj.rs | 123 Runtime::spawn_blocking(move || { in async_send_request()
|