Searched refs:blocking_task (Results 1 – 9 of 9) sorted by relevance
| /external/crosvm/base_tokio/src/ |
| D | tube.rs | 16 let blocking_task = tokio::task::spawn_blocking(move || { in recv_send() localVariable
23 assert_eq!(blocking_task.await.unwrap(), 16u8); in recv_send()
|
| /external/cronet/tot/base/threading/ |
| D | scoped_blocking_call_unittest.cc | 511 auto blocking_task = BindLambdaForTesting([&](int task_index) { in TEST_F() local
526 BindOnce(blocking_task, 0)); in TEST_F()
533 BindOnce(blocking_task, 1)); in TEST_F()
540 BindOnce(blocking_task, 2)); in TEST_F()
578 auto blocking_task = BindLambdaForTesting([&](int task_index) { in TEST_F() local
600 BindOnce(blocking_task, 0)); in TEST_F()
607 BindOnce(blocking_task, 1)); in TEST_F()
614 BindOnce(blocking_task, 2)); in TEST_F()
|
| /external/cronet/stable/base/threading/ |
| D | scoped_blocking_call_unittest.cc | 511 auto blocking_task = BindLambdaForTesting([&](int task_index) { in TEST_F() local
526 BindOnce(blocking_task, 0)); in TEST_F()
533 BindOnce(blocking_task, 1)); in TEST_F()
540 BindOnce(blocking_task, 2)); in TEST_F()
578 auto blocking_task = BindLambdaForTesting([&](int task_index) { in TEST_F() local
600 BindOnce(blocking_task, 0)); in TEST_F()
607 BindOnce(blocking_task, 1)); in TEST_F()
614 BindOnce(blocking_task, 2)); in TEST_F()
|
| /external/rust/android-crates-io/crates/tokio/src/util/ |
| D | trace.rs | 84 …pub(crate) fn blocking_task<Fn, Fut>(task: Fut, spawn_meta: SpawnMeta<'_>, id: u64) -> Instrumente…
172 … pub(crate) fn blocking_task<Fn, Fut>(task: Fut, _spawn_meta: SpawnMeta<'_>, _id: u64) -> Fut {
|
| /external/crosvm/cros_async/src/sys/windows/ |
| D | handle_executor.rs | 413 let blocking_task = pool.0.spawn(move || { in drop_detached_blocking_pool() localVariable
425 blocking_task.await; in drop_detached_blocking_pool()
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/blocking/ |
| D | pool.rs | 11 use crate::util::trace::{blocking_task, SpawnMeta};
380 blocking_task::<F, BlockingTask<F>>(BlockingTask::new(func), spawn_meta, id.as_u64()); in spawn_blocking_inner()
|
| /external/crosvm/cros_async/src/sys/linux/ |
| D | fd_executor.rs | 503 let blocking_task = pool.0.spawn(move || { in drop_detached_blocking_pool() localVariable
515 blocking_task.await; in drop_detached_blocking_pool()
|
| D | uring_executor.rs | 1149 let blocking_task = pool.0.spawn(move || { in drop_detached_blocking_pool() localVariable
1161 blocking_task.await; in drop_detached_blocking_pool()
|
| /external/rust/android-crates-io/crates/tokio/tests/ |
| D | rt_threaded_alt.rs | 326 fn blocking_task() { in blocking_task() function
|